通过合理配置ThreadPoolExecutor和BlockingQueue可实现高效任务调度：核心参数包括corePoolSize、maximumPoolSize、keepAliveTime、workQueue和handler；推荐使用有界队列ArrayBlockingQueue防止资源耗尽；当队列满且线程达最大值时触发拒绝策略，如CallerRunsPolicy由调用线程执行任务以缓解压力；示例中2核心4最大线程配10容量队列，前2任务由核心线程处理，第3至12入队，第13至14创建非核心线程执行，第15任务由主线程直接运行；应根据业务负载选择队列类型与拒绝策略，确保系统稳定与性能平衡。
在Java中，通过组合使用ThreadPoolExecutor和BlockingQueue可以灵活控制线程池的行为，实现高效的任务调度与资源管理。核心思路是利用BlockingQueue缓存待处理任务，ThreadPoolExecutor根据配置动态调度线程执行这些任务。
理解ThreadPoolExecutor的关键参数
ThreadPoolExecutor的构造函数包含多个重要参数，直接影响任务队列的行为：
- corePoolSize：核心线程数，即使空闲也不会被回收（除非设置allowCoreThreadTimeOut）
- maximumPoolSize：最大线程数，当任务队列满时可扩容至此数量
- keepAliveTime：非核心线程空闲后的存活时间
- workQueue：BlockingQueue实现，用于存放等待执行的任务
- threadFactory：自定义线程创建方式（可选）
- handler：拒绝策略，当队列和线程池都满时触发
选择合适的BlockingQueue类型
不同类型的阻塞队列会影响线程池的工作模式：
- LinkedBlockingQueue：无界队列，可能导致内存溢出，但不会触发拒绝策略
- ArrayBlockingQueue：有界队列，需指定容量，推荐用于生产环境防止资源耗尽
- SynchronousQueue：不存储元素，每个插入必须等待对应移除，适合高并发短任务
- PriorityBlockingQueue：支持优先级排序的任务队列
例如，使用有界队列为佳实践：
立即学习“Java免费学习笔记（深入）”；
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
构建线程池并提交任务
以下是一个完整示例，展示如何组合使用ThreadPoolExecutor和ArrayBlockingQueue：
import java.util.concurrent.*;
public class TaskQueueExample {
public static void main(String[] args) {
int corePoolSize = 2;
int maximumPoolSize = 4;
long keepAliveTime = 60L;
BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10);
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
TimeUnit.SECONDS,
queue,
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略
);
// 提交15个任务
for (int i = 0; i < 15; i++) {
final int taskId = i;
executor.execute(() -> {
System.out.println("任务 " + taskId + " 正在由线程 " + Thread.currentThread().getName() + " 执行");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
}
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
}
}
运行逻辑说明：
- 前2个任务由核心线程执行
- 后续任务进入队列（最多10个）
- 第13个任务到来时，队列已满，创建新线程（非核心），直到达到maximumPoolSize=4
- 超出容量的任务将由CallerRunsPolicy处理，即由调用线程直接执行
合理设置拒绝策略
当线程池和队列都满时，可通过setRejectedExecutionHandler指定策略：
- AbortPolicy：抛出RejectedExecutionException（默认）
- CallerRunsPolicy：由提交任务的线程亲自执行
- DiscardPolicy：静默丢弃任务
- DiscardOldestPolicy：丢弃队列中最老任务，重试提交
可根据业务场景选择，例如对数据完整性要求高的系统建议使用CallerRunsPolicy减缓流量。
基本上就这些。关键是根据实际负载选择队列类型、合理设定线程数和队列大小，并配合恰当的拒绝策略，才能发挥线程池最大效用。
