Java高并发线程池实战：参数调优与任务拒绝对策

Java高并发场景下线程池是支撑系统吞吐的核心组件。ThreadPoolExecutor的参数配置不当会导致任务排队激增、线程空转甚至OOM。本文围绕线程池的核心参数、排队策略、拒绝策略与动态调优，给出可落地的实战配置与示例代码。

Java线程池核心参数与工作流程

ThreadPoolExecutor核心参数包括corePoolSize（核心线程数）、maximumPoolSize（最大线程数）、keepAliveTime（非核心线程空闲存活）、workQueue（任务队列）与线程工厂、拒绝策略。任务提交后：线程数小于corePoolSize则新建核心线程，达到corePoolSize后任务入队，队列满且未达maximumPoolSize才新建非核心线程，两者都满则触发拒绝策略。

ThreadPoolExecutor pool = new ThreadPoolExecutor(
    8,                          // 核心线程
    32,                         // 最大线程
    60, TimeUnit.SECONDS,       // 非核心空闲60秒回收
    new LinkedBlockingQueue<>(2048),
    new NamedThreadFactory("order-task"),
    new ThreadPoolExecutor.AbortPolicy() // 拒绝抛RejectedExecutionException
);

队列选择与拒绝策略

队列选型直接影响吞吐：LinkedBlockingQueue无界队列可避免拒绝但会让任务无限堆积；ArrayBlockingQueue有界队列适合限流。生产建议用有界队列+显式拒绝，用CallerRunsPolicy（调用者执行）作为兜底，让上游感知压力而不是静默丢弃。

// 有界队列 + 调用者执行兜底
ThreadPoolExecutor pool = new ThreadPoolExecutor(
    16, 16, 60, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(1000),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

CallerRunsPolicy会让提交任务的线程直接执行任务，压力传导给上游，同时避免任务丢失，适合要求不丢任务的交易类场景。AbortPolicy适合可以重试的异步场景。

线程池超时与Future获取结果

用submit提交任务返回Future，get(超时)可以控制单个任务的执行上限。超时后任务仍在后台执行，Future会抛TimeoutException，此时需要按业务决定是取消任务还是等待结果。

Future future = pool.submit(() -> fetchRemoteData());

try {
    String result = future.get(3, TimeUnit.SECONDS);
    System.out.println(result);
} catch (TimeoutException e) {
    future.cancel(true); // 尝试中断任务线程
    log.warn("任务超时，已取消");
} catch (ExecutionException e) {
    log.error("任务执行异常", e.getCause());
}

// 运行时动态调整线程池参数
pool.setCorePoolSize(newCore);
pool.setMaximumPoolSize(newMax);
// 动态修改队列容量需自定义可扩容队列