线程池
1. 概述
在多线程编程中，线程池是一种管理和复用线程的机制，它能够有效地减少线程创建和销毁的开销，提高程序的性能和资源利用率。线程池通常用于处理大量短生命周期的任务，如网络请求、文件处理等。
1.1 为什么需要线程池？
- 减少线程创建和销毁的开销：每次创建和销毁线程都会消耗系统资源，线程池可以复用线程，减少这些开销。
- 控制并发线程数量：线程池可以限制同时运行的线程数量，避免系统资源被过度消耗。
- 提高响应速度：线程池可以预先创建线程，当任务到达时可以直接使用，减少等待时间。
2. Java 中的线程池
Java 提供了 java.util.concurrent 包来支持线程池的实现。主要的线程池接口和类包括：
Executor：执行提交的任务的接口。ExecutorService：扩展了Executor，提供了管理终止和跟踪异步任务进度的方法。ThreadPoolExecutor：一个可扩展的线程池实现。Executors：提供了创建不同类型线程池的工厂方法。
2.1 创建线程池
Java 提供了几种常用的线程池创建方法，通过 Executors 类可以方便地创建不同类型的线程池。
2.1.1 固定大小的线程池
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);
这个线程池有固定数量的线程，当所有线程都在忙时，新任务会进入队列等待。
2.1.2 可缓存的线程池
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
这个线程池会根据需要创建新线程，空闲线程会被回收。
2.1.3 单线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
这个线程池只有一个线程，所有任务按顺序执行。
2.2 提交任务
线程池创建后，可以通过 submit 方法提交任务。
fixedThreadPool.submit(() -> {
System.out.println("Task is running in " + Thread.currentThread().getName());
});
2.3 关闭线程池
线程池使用完毕后，应该关闭以释放资源。
fixedThreadPool.shutdown();
3. 线程池的配置
ThreadPoolExecutor 提供了丰富的配置选项，可以根据需求调整线程池的行为。
3.1 核心线程数和最大线程数
ThreadPoolExecutor executor = new ThreadPoolExecutor(
10, // 核心线程数
20, // 最大线程数
60L, TimeUnit.SECONDS, // 线程空闲时间
new LinkedBlockingQueue<Runnable>() // 任务队列
);
3.2 任务队列
任务队列用于存储等待执行的任务，常用的队列类型有：
LinkedBlockingQueue：无界队列，任务可以无限添加。ArrayBlockingQueue：有界队列，需要指定队列大小。SynchronousQueue：直接提交任务，不存储任务。
3.3 拒绝策略
当线程池无法接受新任务时，可以配置拒绝策略。
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
常用的拒绝策略有：
AbortPolicy：直接抛出RejectedExecutionException。CallerRunsPolicy：由提交任务的线程执行任务。DiscardPolicy：直接丢弃任务。DiscardOldestPolicy：丢弃队列中最旧的任务。
4. 实践练习
4.1 创建一个固定大小的线程池，提交多个任务
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
for (int i = 0; i < 10; i++) {
final int taskId = i;
fixedThreadPool.submit(() -> {
System.out.println("Task " + taskId + " is running in " + Thread.currentThread().getName());
});
}
fixedThreadPool.shutdown();
}
}
4.2 自定义线程池配置
import java.util.concurrent.*;
public class CustomThreadPoolExample {
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, // 核心线程数
4, // 最大线程数
60L, TimeUnit.SECONDS, // 线程空闲时间
new ArrayBlockingQueue<>(10), // 任务队列
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略
);
for (int i = 0; i < 15; i++) {
final int taskId = i;
executor.submit(() -> {
System.out.println("Task " + taskId + " is running in " + Thread.currentThread().getName());
});
}
executor.shutdown();
}
}
5. 总结
线程池是多线程编程中的重要工具，能够有效地管理和复用线程，提高程序的性能和资源利用率。通过 Executors 类可以方便地创建不同类型的线程池，而 ThreadPoolExecutor 提供了更灵活的配置选项。掌握线程池的使用和配置，对于编写高效的多线程程序至关重要。
6. 进一步学习
- 并发集合：学习如何使用
ConcurrentHashMap等并发集合来处理多线程环境下的数据共享。 - Lambda 表达式和 Stream API：探索如何使用 Lambda 表达式和 Stream API 简化多线程编程。
- 性能调优：了解如何通过调整线程池配置和使用性能分析工具来优化多线程程序的性能。
通过不断实践和学习，你将能够更好地掌握线程池的使用，编写出高效、稳定的多线程程序。