Does Helidon MP support non-blocking REST calls with backpressure? #3622

khovanskiy · 2021-11-05T20:10:20Z

khovanskiy
Nov 5, 2021

According to the specification, we can use AsyncRequest and @Suspended, but all examples use an additional thread pool. So how can we set up the backpressure of incoming requests at the transport level (Netty)?

@Path("/example")
public class ExampleService {

    private static ExecutorService executor = Executors.newFixedThreadPool(10);

    @Path("/test")
    @GET
    public void test(
        @QueryParam("param1") String param1, 
        @QueryParam("param2") String param2, 
        @Suspended AsyncResponse ar
    ) {
        executor.execute( () -> {
            final var result = doSomeLongTask();
            ar.resume(result);
        });
    }
}