Java中创建线程池有哪些方式？各有什么特点？

Java中创建线程池主要有以下几种方式：

1. 使用Executors工厂类创建线程池

Executors类提供了一系列静态工厂方法，用于创建不同类型的线程池：

1.1 newFixedThreadPool

创建一个固定大小的线程池。

ExecutorService executor = Executors.newFixedThreadPool(5);

特点：

• 线程池中的线程数量是固定的，不会随着任务的增加而增加
• 当有新任务提交时，如果有空闲线程，则立即执行；如果没有空闲线程，则任务会等待在队列中
• 适用于负载较重的服务器，可以限制资源的消耗
• 底层实现：使用LinkedBlockingQueue作为任务队列，队列长度为Integer.MAX_VALUE，可能导致OOM

1.2 newCachedThreadPool

创建一个可缓存的线程池。

ExecutorService executor = Executors.newCachedThreadPool();

特点：

• 线程池中的线程数量不固定，可以根据需要自动调整
• 当有新任务提交时，如果有空闲线程，则复用空闲线程；如果没有空闲线程，则创建新线程
• 空闲线程会被保留60秒，如果在这段时间内没有新任务，则会被回收
• 适用于执行很多短期异步任务的程序
• 底层实现：使用SynchronousQueue作为任务队列，没有容量限制，可能导致创建大量线程而耗尽资源

1.3 newSingleThreadExecutor

创建一个单线程化的线程池。

ExecutorService executor = Executors.newSingleThreadExecutor();

特点：

• 线程池中只有一个线程
• 所有任务按照提交的顺序执行（FIFO）
• 适用于需要保证任务顺序执行的场景
• 底层实现：使用LinkedBlockingQueue作为任务队列，队列长度为Integer.MAX_VALUE，可能导致OOM

1.4 newScheduledThreadPool

创建一个支持定时及周期性任务执行的线程池。

ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);

特点：

• 线程池中的线程数量是固定的
• 可以执行定时任务和周期性任务
• 适用于需要定时执行任务的场景
• 底层实现：使用DelayedWorkQueue作为任务队列

1.5 newWorkStealingPool

创建一个工作窃取线程池（Java 8引入）。

ExecutorService executor = Executors.newWorkStealingPool();

特点：

• 使用ForkJoinPool作为底层实现
• 线程池中的线程数量会根据处理器数量自动调整
• 适用于执行耗时较长的任务，可以提高CPU利用率
• 每个线程都有自己的任务队列，当一个线程完成自己的任务后，会从其他线程的队列中"窃取"任务执行

2. 直接使用ThreadPoolExecutor构造函数创建线程池

除了使用Executors工厂类，我们还可以直接使用ThreadPoolExecutor的构造函数来创建线程池，这样可以更灵活地配置线程池的参数。

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    int corePoolSize,          // 核心线程数
    int maximumPoolSize,       // 最大线程数
    long keepAliveTime,        // 空闲线程存活时间
    TimeUnit unit,             // 时间单位
    BlockingQueue<Runnable> workQueue,  // 任务队列
    ThreadFactory threadFactory,        // 线程工厂
    RejectedExecutionHandler handler    // 拒绝策略
);

参数说明：

• corePoolSize：核心线程数，线程池中保持的线程数量，即使它们是空闲的
• maximumPoolSize：最大线程数，线程池中允许的最大线程数量
• keepAliveTime：空闲线程存活时间，当线程数大于核心线程数时，空闲线程在终止前等待新任务的最长时间
• unit：时间单位，用于指定keepAliveTime的时间单位
• workQueue：任务队列，用于保存等待执行的任务的阻塞队列
• threadFactory：线程工厂，用于创建新线程
• handler：拒绝策略，当任务队列已满并且线程数达到最大线程数时，用于处理新任务的策略

特点：

• 可以灵活配置线程池的各个参数
• 可以根据实际需求选择合适的任务队列和拒绝策略
• 适用于对线程池有特殊要求的场景

3. 使用ForkJoinPool（Java 7引入）

ForkJoinPool是Java 7引入的一种特殊的线程池，用于执行分治任务。

ForkJoinPool pool = new ForkJoinPool();
ForkJoinPool pool = new ForkJoinPool(int parallelism);

特点：

• 适用于执行分治任务，即将大任务分解为小任务并行执行
• 使用工作窃取算法，提高CPU利用率
• 每个线程都有自己的任务队列，当一个线程完成自己的任务后，会从其他线程的队列中"窃取"任务执行
• 适用于计算密集型任务

4. 使用CompletableFuture（Java 8引入）

CompletableFuture是Java 8引入的一种异步编程工具，它内部使用ForkJoinPool.commonPool()作为默认的线程池。

CompletableFuture.supplyAsync(() -> {
    // 任务代码
    return result;
});

特点：

• 简化了异步编程的复杂性
• 支持函数式编程风格
• 可以链式组合多个异步操作
• 适用于需要处理异步任务链的场景

线程池的拒绝策略

当任务队列已满并且线程数达到最大线程数时，线程池会使用拒绝策略来处理新任务。Java提供了四种内置的拒绝策略：

1. AbortPolicy：默认策略，直接抛出RejectedExecutionException异常
2. CallerRunsPolicy：由提交任务的线程来执行该任务
3. DiscardPolicy：直接丢弃任务，不抛出异常
4. DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试重新提交新任务

此外，我们还可以自定义拒绝策略，实现RejectedExecutionHandler接口。

线程池的任务队列

线程池的任务队列用于保存等待执行的任务。Java提供了多种阻塞队列作为任务队列：

1. LinkedBlockingQueue：基于链表的阻塞队列，队列长度可以是固定的，也可以是Integer.MAX_VALUE
2. ArrayBlockingQueue：基于数组的阻塞队列，必须指定队列长度
3. SynchronousQueue：不存储元素的阻塞队列，每个插入操作必须等待另一个线程的移除操作
4. PriorityBlockingQueue：支持优先级的阻塞队列
5. DelayedWorkQueue：支持延迟任务的阻塞队列，用于ScheduledThreadPoolExecutor

线程池的生命周期

线程池的生命周期包括以下几种状态：

1. RUNNING：接受新任务，并处理队列中的任务
2. SHUTDOWN：不接受新任务，但处理队列中的任务
3. STOP：不接受新任务，也不处理队列中的任务，并中断正在处理的任务
4. TIDYING：所有任务已终止，workerCount为0，线程池转换为TIDYING状态时，会调用terminated()方法
5. TERMINATED：terminated()方法执行完成

线程池的最佳实践

1. 合理设置线程池的大小：

   • CPU密集型任务：线程数不宜过多，一般设置为CPU核心数+1
   • IO密集型任务：线程数可以设置得多一些，一般设置为CPU核心数*2

2. 使用有界队列：

   • 避免使用无界队列，防止内存溢出
   • 根据任务类型和系统资源选择合适的队列类型和大小

3. 自定义线程工厂：

   • 为线程设置有意义的名称，便于调试和监控
   • 可以设置线程的优先级、是否为守护线程等属性

4. 处理异常：

   • 任务执行过程中可能会抛出异常，需要妥善处理
   • 可以通过自定义ThreadFactory的UncaughtExceptionHandler来处理未捕获的异常

5. 合理选择拒绝策略：

   • 根据业务需求选择合适的拒绝策略
   • 可以自定义拒绝策略，实现更灵活的任务处理方式

6. 监控线程池：

   • 定期检查线程池的状态和任务执行情况
   • 可以通过线程池提供的方法获取线程池的状态信息

7. 合理关闭线程池：

   • 使用shutdown()方法平滑关闭线程池
   • 使用awaitTermination()方法等待任务执行完成
   • 如果需要立即关闭，可以使用shutdownNow()方法

线程池创建方式对比

参考文档：

1. Java官方文档 - Executor
2. Java官方文档 - ThreadPoolExecutor
3. Java官方文档 - Executors
4. Java官方文档 - ForkJoinPool
5. Java官方文档 - CompletableFuture