如何正确使用Java ExecutorService

Java ExecutorService 是一个用于管理线程池和异步执行任务的接口。正确使用 ExecutorService 可以提高应用程序的性能和响应能力。以下是如何正确使用 Java ExecutorService 的一些建议：

1. 创建 ExecutorService 实例： 使用 Executors 类的工厂方法创建 ExecutorService 实例。例如，创建一个固定大小的线程池：

   ExecutorService executorService = Executors.newFixedThreadPool(5);
   

   或者创建一个单线程的线程池：

   ExecutorService executorService = Executors.newSingleThreadExecutor();
   

2. 提交任务： 使用 ExecutorService 的 submit() 或 execute() 方法提交任务。submit() 方法返回一个 Future 对象，可以用于获取任务的执行结果或取消任务。execute() 方法没有返回值，只能用于执行 Runnable 任务。

   Future<?> future = executorService.submit(() -> {
       // 你的任务代码
   });
   

   或者

   executorService.execute(() -> {
       // 你的任务代码
   });
   

3. 处理任务结果： 如果使用 submit() 方法提交任务，可以通过 Future 对象获取任务的执行结果或取消任务。

   try {
       Object result = future.get(); // 获取任务执行结果
       future.cancel(true); // 取消任务
   } catch (InterruptedException | ExecutionException e) {
       e.printStackTrace();
   }
   

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

   executorService.shutdown(); // 平滑地关闭 ExecutorService，等待已提交的任务执行完成
   

   或者

   List<Runnable> remainingTasks = executorService.shutdownNow(); // 立即关闭 ExecutorService，尝试停止所有正在执行的任务
   

   注意：在关闭 ExecutorService 之后，不要再次提交新任务，否则会抛出 RejectedExecutionException 异常。

遵循以上建议，可以确保正确使用 Java ExecutorService，提高应用程序的性能和响应能力。