java Executor执行器线程池如何配置

在Java中，ExecutorService 是一个接口，它提供了一种将任务提交给执行的机制。通常，我们使用 Executors 工厂类来创建不同类型的线程池。以下是一些常见的线程池配置方式：

1. Fixed Thread Pool - 固定大小的线程池。

   ExecutorService fixedThreadPool = Executors.newFixedThreadPool(int nThreads);
   

   这里 nThreads 是线程池中的固定线程数。即使线程因异常而终止，也会立即用新的线程替换它，因此线程池的大小不会改变。

2. Cached Thread Pool - 可缓存的线程池。

   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
   

   这种线程池会根据需要创建新线程，但在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言，这些线程池通常可以提高程序性能。

3. Single Thread Executor - 单线程的执行器。

   ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
   

   这种线程池只有一个线程，它按照任务在队列中出现的顺序执行任务。

4. Scheduled Thread Pool - 支持定时及周期性任务执行的线程池。

   ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(int corePoolSize);
   

   这种线程池可以安排命令在给定的延迟后运行，或者定期执行。

5. Work Stealing Pool - 工作窃取线程池。

   ExecutorService workStealingPool = Executors.newWorkStealingPool();
   

   这种线程池使用多个队列来减少线程间的竞争，并提供更好的可伸缩性。

配置线程池时，需要考虑以下几个关键参数：

• corePoolSize - 核心线程数，即使空闲也不会被回收（除非设置了允许核心线程超时）。
• maximumPoolSize - 最大线程数，线程池能容纳的最大线程数量。
• keepAliveTime - 非核心线程的空闲时间，超过这个时间会被回收。
• unit - keepAliveTime 参数的时间单位。
• workQueue - 用于保存等待执行任务的队列。
• threadFactory - 用于创建新线程的工厂。
• handler - 当任务无法被接受时的处理策略。

例如，如果你想要创建一个核心线程数为5，最大线程数为10，非核心线程空闲时间为60秒的线程池，可以使用以下代码：

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    5, // corePoolSize
    10, // maximumPoolSize
    60L, // keepAliveTime
    TimeUnit.SECONDS, // unit
    new LinkedBlockingQueue<Runnable>() // workQueue
);

在实际应用中，线程池的大小应该根据应用程序的具体需求和运行环境来调整。例如，CPU密集型任务可能需要接近CPU核心数的线程数，而I/O密集型任务可能需要更多的线程来保持CPU忙碌。