在 Spring Boot Rest API 中关闭 ExecutorService

Question

正在构建一个部署在 weblogic 12c 上的 spring boot rest api 应用程序。 我的要求之一是在每个传入请求上运行一些长时间运行的任务。 传入的休息请求可能会导致多个异步任务执行。

由于我不关心响应，也不关心这些任务会导致的任何异常，我选择使用 ExecutorService 而不是 Callable 或 CompletableFuture。

ExecutorService executorService =
  Executors.newFixedThreadPool(2, new CustomizableThreadFactory("-abc-"));

然后对于我在控制器中收到的传入请求，运行两个 for 循环并将这些任务分配给 ExecutorService：

for (final String orderId : orderIds) {
        for (final String itemId : itemIds) {               
            exec.execute(new Runnable() {
                public void run() { 
                    try {           
                         //call database operation
                    }catch(Throwable t) {
                       logger.error("EXCEPTION with {} , {}" ,orderId,itemId 
                    )
                }   
            });
        }//for          
    }//for

我的问题是关于关闭 ExecutorService。 我知道正常关机（shutdown）、混合关机（awaitTermination）或突然关机（shutdownNow）

对于 rest api 应用程序，这三者之间的首选方法是什么？

对于可以创建的线程池的数量是否有任何限制，即创建的 ExecutorService 线程池的数量将由传入请求的数量驱动

Answer 1

我们目前有类似的要求，这是一个很难解决的问题，因为您想使用正确的锤子。有很多重量级的解决方案来编排长时间运行的进程，例如 SpringBatch。

首先，尽管不要打扰停止和启动 ExecutorService。该类的全部意义在于将线程管理的负担从您手中卸下，因此您无需自己创建和停止线程。所以你不需要管理经理。

但要小心你的方法。无需使用队列或其他负载平衡技术来智能地平衡应用程序中跨实例的长时间运行的进程。或者管理线程死亡时发生的事情，您可能会陷入困境。总的来说，我会说现在直接与线程或线程池交互并使用更高级别的解决方案来解决这类问题没有多大意义。

Answer 2

awaitTermination 通常更安全一些，而shutdownNow 更有力。如果您希望执行程序尽快关闭，但仅在它完成创建它要执行的所有操作之后，在函数方法甚至可运行方法中使用 awaitTermination 通常是一个好主意。换句话说，当执行器没有正在执行的活动任务时。 例如）

ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime.availableProcessors);
Observable.of(items).schedule(Schedulers.from(executor)).flatMap(item -> {
   ... // this block represents a task that the executor will execute in a worker thread
}).onSubscribe(onNext -> 
   logItem(onNext), throwable -> 
   throwable.printStackTrace(), /* onComplete */ () -> 
   executor.awaitTermination(60, TimeUnit.Seconds)
);
... // you need to shutdown asap because these other methods below are also doing some computation/io-intensive stuff

现在，当这个方法完成时，它会调用awaitTermination，如果它没有执行任何任务，它将立即关闭池，或者如果任务仍在执行，则等待长达 60 秒。

在大多数情况下，如果 60 秒不活动，线程或工作人员将停止活动，因为这通常是默认设置。

另一方面，如果您希望任务在抛出异常、安全漏洞或另一个模块/服务失败时立即停止执行（举一些例子），您可能需要使用 shutdownNow () 立即停止所有任务，无需等待。

如果您不希望在出现异常时继续执行任务 - 即不再有理由返回列表，我在两者之间进行选择的建议是在您的 catch 块中使用 shutdownNow鉴于其中一项未添加到列表中，向客户提供的项目。 否则，我建议在您的 try-catch 设置为一分钟后使用awaitTermination，以便在线程池执行完您给它的所有任务后立即安全地关闭线程池。但只有在您知道执行者将不负责执行任何更多任务的情况下才这样做。

简单的shutdown，如果你可以选择的话，也是一个好方法。根据 Oracle 文档，shutdown 将拒绝所有传入的任务，但等待当前任务完成执行。

如果您不确定何时需要关闭执行程序，最好使用@PreDestroy 方法，以便执行程序在您的 bean 上调用 destroy 方法之前执行：

@PreDestroy
private void cleanup(){
   executor.shutdown();
}