如何正确使用java ExecutorService管理线程

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给执行的机制，同时还能控制并发执行的数量。以下是如何正确使用ExecutorService来管理线程的步骤：

1. 创建一个线程池： 使用Executors类的静态方法来创建一个ExecutorService实例。例如，如果你想要一个固定大小的线程池，可以使用Executors.newFixedThreadPool(int nThreads)。

   ExecutorService executor = Executors.newFixedThreadPool(4);
   

2. 提交任务： 使用execute(Runnable command)方法提交实现了Runnable接口的任务，或者使用submit(Callable<T> task)方法提交实现了Callable<T>接口的任务。submit方法返回一个Future<T>对象，可以用来获取任务的执行结果。

   executor.execute(new MyRunnableTask());
   Future<Integer> future = executor.submit(new MyCallableTask());
   

3. 关闭线程池： 当不再需要线程池时，应该优雅地关闭它。这可以通过调用shutdown()或shutdownNow()方法来完成。

   • shutdown()：启动有序关闭，在此过程中，先前提交的任务将被执行，但不会接受新的任务。
   • shutdownNow()：尝试停止所有正在执行的任务，停止处理等待队列中的任务，并返回等待执行的任务列表。

   executor.shutdown(); // 不再接受新任务，但会等待已提交的任务完成
   // 或者
   List<Runnable> remainingTasks = executor.shutdownNow(); // 尝试立即停止所有任务
   

4. 等待任务完成： 如果你需要等待所有任务完成，可以使用awaitTermination(long timeout, TimeUnit unit)方法。这个方法会阻塞，直到所有任务完成执行或者超时发生。

   try {
       if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
           executor.shutdownNow(); // 超时后强制关闭
       }
   } catch (InterruptedException e) {
       executor.shutdownNow(); // 如果当前线程被中断，也强制关闭
       Thread.currentThread().interrupt(); // 保留中断状态
   }
   

5. 处理异常： 在任务中捕获和处理异常是很重要的。如果任务在执行过程中抛出未捕获的异常，它将被Thread.UncaughtExceptionHandler处理。你可以为线程池设置一个全局的异常处理器。

   Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
       @Override
       public void uncaughtException(Thread t, Throwable e) {
           System.err.println("Uncaught exception in thread " + t.getName() + ": " + e.getMessage());
       }
   });
   

6. 使用ThreadPoolExecutor进行更细粒度的控制： 如果你需要更多的控制，比如自定义线程工厂、拒绝策略等，可以直接创建ThreadPoolExecutor的实例。

   ThreadPoolExecutor executor = new ThreadPoolExecutor(
       4, // 核心线程数
       10, // 最大线程数
       60L, TimeUnit.SECONDS, // 线程空闲时间
       new LinkedBlockingQueue<>(100), // 任务队列
       new CustomThreadFactory(), // 自定义线程工厂
       new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
   );
   

使用ExecutorService时，遵循这些步骤可以帮助你更好地管理线程，避免资源泄露，并确保应用程序的稳定性和性能。