Java线程池任务队列实战解析

在Java中，通过组合使用ThreadPoolExecutor和BlockingQueue可以灵活控制线程池的行为，实现高效的任务调度与资源管理。核心思路是利用BlockingQueue缓存待处理任务，ThreadPoolExecutor根据配置动态调度线程执行这些任务。

理解ThreadPoolExecutor的关键参数

ThreadPoolExecutor的构造函数包含多个重要参数，直接影响任务队列的行为：

• corePoolSize：核心线程数，即使空闲也不会被回收（除非设置allowCoreThreadTimeOut）
• maximumPoolSize：最大线程数，当任务队列满时可扩容至此数量
• keepAliveTime：非核心线程空闲后的存活时间
• workQueue：BlockingQueue实现，用于存放等待执行的任务
• threadFactory：自定义线程创建方式（可选）
• handler：拒绝策略，当队列和线程池都满时触发

选择合适的BlockingQueue类型

不同类型的阻塞队列会影响线程池的工作模式：

• LinkedBlockingQueue：无界队列，可能导致内存溢出，但不会触发拒绝策略
• ArrayBlockingQueue：有界队列，需指定容量，推荐用于生产环境防止资源耗尽
• SynchronousQueue：不存储元素，每个插入必须等待对应移除，适合高并发短任务
• PriorityBlockingQueue：支持优先级排序的任务队列

例如，使用有界队列为佳实践：

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减缓流量。

基本上就这些。关键是根据实际负载选择队列类型、合理设定线程数和队列大小，并配合恰当的拒绝策略，才能发挥线程池最大效用。