如何在不丢失任务的情况下关闭和重新实例化执行者服务

Question

我不完全理解，我应该如何在偶尔即将到来的任务的应用程序中实现ExecutorService。每项任务运行约15分钟（长20倍）。有时一天有10个任务，有时一整周都没有。

因此，在执行了一些任务之后，如果队列中没有剩余的任务，我想关闭执行器，因为它不再需要了，这样垃圾收集器就可以继续它的工作。调用shutdown后，没有新任务排队等待执行器。

现在，我的问题是，我必须确保所有的任务都完成了。这意味着，在调用关闭后，我必须确保在提交新任务之前实例化了新的执行器服务。我必须等到旧的执行者服务关闭（或终止？）并初始化一个新的。我应该如何实现这一点？

这是我的方法：

// sync block to check for each task if a new Executor Service has to be created before submitting the task
synchronized (this) {
    // do I have to check both isSutdown and isTerminated?
    if (null == businessTaskExecutor || businessTaskExecutor.isShutdown() || businessTaskExecutor.isTerminated()) {
        // simply init a new one
        businessTaskExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(1);
    } else if (businessTaskExecutor.isTerminating()) {
        // the termination process has started and is not done.
        // Do I have to wait for the old executor or can I simply init a new one without waiting?
        while (!businessTaskExecutor.isTerminated()) { }
        businessTaskExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(1);
    }
}
Future<?> future = businessTaskExecutor.submit(() -> new BusinessTaskRunnable(businessTask));
if (future.isDone() && businessTaskExecutor.getQueue().isEmpty()) {
    businessTaskExecutor.shutdown();
    try {
        if (!businessTaskExecutor.awaitTermination(1, TimeUnit.HOURS)) {
            businessTaskExecutor.shutdownNow();
        }
    } catch (InterruptedException ex) {
        businessTaskExecutor.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

说明：

如果执行器为null/shutdown/terminated，我将初始化一个新的执行器，到目前为止一切正常。否则，如果执行器当前正在终止（因为调用了shutdown），则执行器不会接受进一步的任务。所以我等到它被终止，然后初始化一个新的。之后我提交我的任务。。。我只在队列中没有其他任务时关闭执行器。尽管我等了一个小时，因为可能还有一个正在运行的任务。

我希望的行为有更好的实现吗？

其他信息：我使用ThreadPoolExecutor，因为我需要getQueue（）来检查它是否为空。我还可以在不同的实现中使用任何其他类型的Executor服务。

提前感谢。

Answer 1

我想关闭执行器，因为它不再需要了，这样垃圾收集器就可以工作了。

但它是需要的，这就是为什么你要重新创建它。无论执行器是否关闭，GC都可以完成它的工作（除非您已经设法用ThreadLocal创建了一些非常特殊的东西，以某种方式将对象绑定到执行器）。

我读到只有在我关闭执行器时才会调用垃圾收集器。

你要么记错了，要么读到了不好的信息。

因为您使用的是单个线程，所以实际上不需要担心池的配置。一个长寿命的执行者。新固定线程池（1） 就是你所需要的。

如果确实需要释放资源，可以使用新的ThreadPoolExecutor（0,1,30，TimeUnit.SECONDS，new LinkedBlockingQueue）之类的工具来配置核心池大小