如何确保 Java ExecutorService 关闭期间任务终止

Java ExecutorService 关闭：确保任务终止

在处理 java ExecutorService 时，一个关键的方面是处理关闭过程以确保所有任务都正确终止。当任务执行期间发生超时或其他中断时，这就变得具有挑战性。

自定义方法

提供的代码演示了执行 CallableTask 对象的 ExecutorService 面临困难的场景所有任务完成后关闭。此问题源于超过超时阈值的任务线程可能保持活动状态，从而阻止执行终止。

推荐的解决方案

为了解决此问题，Oracle API ExecutorService 的文档建议采用以下方法：

<code class="java">void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); 
   try {
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); 
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     pool.shutdownNow(); 
     Thread.currentThread().interrupt();
   }
}</code>

此方法可确保有序关闭过程：

• shutdown()：禁用新任务的提交。
• awaitTermination()：等待现有任务超时完成。
• shutdownNow()：如果awaitTermination()失败，则中断正在执行的任务，强制终止它们。

关闭相关方法简述

• shutdown()：启动有序关闭，执行已提交的任务，但拒绝新任务。
• shutdownNow()：尝试停止所有活动任务，停止待处理任务，并返回未完成任务的列表。
• awaitTermination()：阻塞，直到所有任务完成（无论是完成还是中断）。

其他提示

要延长顽固任务的关闭超时时间，请将awaitTermination():

<code class="java">if (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

修改为：

<code class="java">while (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

通过实施这些技术，您可以增强 ExecutorService 关闭过程的可靠性，确保正确的任务终止和系统清理。

以上是如何确保 Java ExecutorService 关闭期间任务终止的详细内容。更多信息请关注PHP中文网其他相关文章！