CompletableFuture.runAsync 是否有线程限制

Question

我有一个 Rest api，它在其中调用如下所示的异步调用

 CompletableFuture.runAsync(() -> {
                        // method call or code to be async.
                     try {
                            logger.info("======Before Async method call======with studySchemaEventId: "+enrollmentStudySchemaEventId);
                            this.performSimulation(studyId, enrollmentStudySchemaEventId, cloneOfFile, simulationRunInfo, totalAccrual);
                            logger.info("======After Async method call======with studySchemaEventId: "+enrollmentStudySchemaEventId);
                        } catch (SimulationException e) {
                            logger.error("Error running Async call for performSimulation()", e);
                        }
                    });

当我调用 Rest api 时，它正确执行了异步调用。但是我有一个案例，我调用了 Rest Api，4 次，它执行了 3 次异步调用和第 4 次 Api 调用，我没有看到异步方法被调用。

runAsync() 调用是否有任何限制？或者为什么它在 3 次调用后不调用 Async 方法？

这是休息 API 电话：

    @POST
    @Path("/trigger")
    @Consumes(MediaType.MULTIPART_FORM_DATA)  
    @ApiOperation(value = "Trigger Simulation",  tags = "Study Event Simulation")
    public Response triggerSimulation( 
            @FormDataParam("file") InputStream file,
            @FormDataParam("file") FormDataContentDisposition fileDetail ,
            @FormDataParam("simulationRunInfo") SimulationRunInfo simulationRunInfo
  
    ) 
    {

// some other logic
// Async code here

}

Answer 1

你遇到的是ForkJoinPool.commonPool()中配置的线程数。

分配给runAsSync的任务由ForkJoinPool.commonPool()完成。该池是根据主机中的内核数配置的。看来你有4核。

默认情况下，公共池的大小：

Runtime.getRuntime().availableProcessors() - 1

您可以更新尺码：

-Djava.util.concurrent.ForkJoinPool.common.parallelism=8

或者，您可以将重载 runAsSync 与 executors 参数一起使用。

CompletableFuture.runAsync 是否有线程限制

Is there any thread limit on CompletableFuture.runAsync

java

multithreading

asynchronous

threadpool

completable-future