ExecutorService 在Java中如何管理线程

在Java中，ExecutorService是一个接口，用于管理和控制线程的执行。它是Java并发包（java.util.concurrent）中的一个关键组件，可以帮助我们更有效地管理和优化线程资源。以下是ExecutorService如何管理线程的一些主要方法：

1. newFixedThreadPool(int nThreads): 创建一个固定大小的线程池，可控制线程最大并发数，超出的线程会在队列中等待。

   ExecutorService executor = Executors.newFixedThreadPool(5);
   

2. newCachedThreadPool(): 创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。

   ExecutorService executor = Executors.newCachedThreadPool();
   

3. newSingleThreadExecutor(): 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序（FIFO, LIFO, 优先级）执行。

   ExecutorService executor = Executors.newSingleThreadExecutor();
   

4. newScheduledThreadPool(int corePoolSize): 创建一个定长线程池，支持定时及周期性任务执行。

   ExecutorService executor = Executors.newScheduledThreadPool(5);
   

5. shutdown(): 正确关闭线程池，不再接受新的任务，但是会继续处理已经提交的任务。

   executor.shutdown();
   

6. shutdownNow(): 试图停止所有正在执行的任务，返回尚未开始执行的任务列表。

   List<Runnable> tasks = executor.shutdownNow();
   

7. awaitTermination(long timeout, TimeUnit unit): 等待所有任务完成执行或者在指定的超时时间内终止。

   executor.awaitTermination(1, TimeUnit.HOURS);
   

8. submit(Runnable task): 提交一个任务用于执行，返回表示该任务的Future对象。

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

9. submit(Callable task): 提交一个Callable任务用于执行，返回表示该任务的Future<T>对象。

   Future<Integer> future = executor.submit(() -> {
       // 任务代码
       return 42;
   });
   

通过使用ExecutorService，我们可以更好地管理线程的生命周期，避免创建过多的线程导致的资源耗尽问题，同时还可以实现任务的异步执行和并发控制。