Java ExecutorService的生命周期管理

Java ExecutorService 的生命周期管理主要包括以下几个阶段：

1. 创建 ExecutorService： 使用 Executors 工厂方法或者直接使用 ThreadPoolExecutor 构造函数来创建一个 ExecutorService 实例。例如：

   // 使用 Executors 工厂方法创建
   ExecutorService executorService = Executors.newFixedThreadPool(5);
   
   // 使用 ThreadPoolExecutor 构造函数创建
   ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
           5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
   

2. 提交任务： 使用 ExecutorService 的 submit() 或 execute() 方法将 Runnable 或 Callable 任务提交给线程池执行。例如：

   executorService.submit(new MyRunnableTask());
   

3. 关闭 ExecutorService： 当不再需要 ExecutorService 时，应该关闭它以释放系统资源。可以使用 shutdown() 或 shutdownNow() 方法来关闭 ExecutorService。

   • shutdown()：优雅地关闭 ExecutorService，不再接受新的任务，但会等待已经提交的任务执行完毕。

     executorService.shutdown();
     

   • shutdownNow()：立即关闭 ExecutorService，尝试停止所有正在执行的任务，并返回尚未开始执行的任务列表。

     List<Runnable> remainingTasks = executorService.shutdownNow();
     

4. 等待 ExecutorService 关闭： 如果需要等待 ExecutorService 完全关闭，可以使用 awaitTermination() 方法。例如：

   try {
       // 等待最多 10 秒钟，直到所有任务执行完毕
       if (!executorService.awaitTermination(10, TimeUnit.SECONDS)) {
           // 超时后，尝试强制关闭
           executorService.shutdownNow();
       }
   } catch (InterruptedException e) {
       // 如果当前线程被中断，尝试强制关闭
       executorService.shutdownNow();
   }
   

遵循以上步骤，可以有效地管理 Java ExecutorService 的生命周期，确保系统资源得到合理分配和释放。