引子
线程的创建和销毁比较消耗资源，所以有一种更加高效快捷的方式管理线程—-线程池。 先来看一下线程池的java模型
Executor：线程池顶级接口，只有一个方法
ExecutorService：真正的线程池接口
void execute(Runnable command) ：执行任务/命令，没有返回值，一般用来执行Runnable
Future submit(Callable task)：执行任务，有返回值，一般又来执行Callable
void shutdown() ：关闭线程池
AbstractExecutorService：基本实现了ExecutorService的所有方法
Th
线程池是Java中一种高效的线程管理工具，它的出现是为了优化线程的创建和销毁过程，因为这两个操作在实际应用中可能会消耗大量资源。线程池通过预先创建一定数量的线程，使得任务能够迅速分配到线程上执行，从而提高系统性能。
线程池的Java模型基于`Executor`接口，它是所有线程池组件的顶级接口。`ExecutorService`是线程池的主要接口，提供了执行任务的方法，如`execute()`用于执行无返回值的`Runnable`任务，以及`submit()`用于执行有返回值的`Callable`任务。`shutdown()`方法用于关闭线程池，停止接收新任务，但会继续执行已提交的任务。
`AbstractExecutorService`类是`ExecutorService`的一个抽象实现，它实现了大部分`ExecutorService`的方法。`ThreadPoolExecutor`是线程池的默认实现类，它允许我们自定义线程池的核心参数，如核心线程数、最大线程数、空闲线程存活时间、工作队列和拒绝策略等。`ScheduledThreadPoolExecutor`则用于实现周期性任务调度。
`Executors`是线程池的工厂类，它提供了多种静态方法来创建不同类型的线程池：
- `newCachedThreadPool()`创建一个可缓存线程池，根据需要创建新线程，当线程空闲超过60秒后会被回收。
- `newFixedThreadPool(int n)`创建一个固定大小的线程池，线程数量固定，适合处理大量重复的任务。
- `newSingleThreadExecutor()`创建一个单线程的线程池，所有任务都会按顺序执行。
- `newScheduledThreadPool(int n)`创建一个支持定时及周期性任务执行的线程池，可以设定延迟或周期性执行任务。
`ThreadPoolExecutor`的关键构造参数包括：
- `corePoolSize`：核心线程数，即使没有任务，这些线程也会保持活动状态。
- `maximumPoolSize`：最大线程数，超过这个数的任务会被放入工作队列。
- `keepAliveTime`：当线程数量超过核心线程数且空闲时，线程等待新任务的最长时间。
- `unit`：`keepAliveTime`的时间单位，如`TimeUnit.SECONDS`。
- `workQueue`：工作队列，存放待执行的任务，如`ArrayBlockingQueue`或`LinkedBlockingQueue`。
- `threadFactory`：用于创建新线程的工厂，可以自定义线程属性。
- `handler`：拒绝策略，当线程池和工作队列都满时，用于处理新任务。
常见的拒绝策略包括：
1. `CallerRunsPolicy`：调用者运行策略，当前线程直接运行被拒绝的任务。
2. `DiscardOldestPolicy`：丢弃最旧任务，将新任务放入队列。
3. `DiscardPolicy`：简单丢弃任务，不做任何处理。
4. `AbortPolicy`：默认策略，抛出`RejectedExecutionException`异常。
在实际编程中，我们可以根据业务需求调整这些参数，以实现最优的线程池配置，确保系统的高并发处理能力和资源利用率。通过合理使用线程池，可以有效地避免因频繁创建和销毁线程而产生的性能开销，提高系统的响应速度和并发能力。
- 1
- 2
前往页