在Java中如何使用Executor框架_Java线程池基本用法解析

陆砚码

2026-10-13 • 👁 0人浏览过

生产环境应手动创建ThreadPoolExecutor，显式配置核心线程数、最大线程数、队列容量和拒绝策略；submit()适用于需结果和异常处理的场景，execute()仅执行无返回任务；shutdown后须调用awaitTermination等待任务完成。怎么创建一个能用的线程池别一上来就写

new ThreadPoolExecutor(...)

，大多数场景直接用

Executors

工厂方法更安全。但要注意：它提供的几个静态方法有隐藏陷阱。

Executors.newFixedThreadPool(int)

底层用的是无界

LinkedBlockingQueue

，任务堆积时可能 OOM

Executors.newCachedThreadPool()

允许无限创建线程，突发流量下容易耗尽系统资源生产环境推荐手动构造

ThreadPoolExecutor

，显式控制核心线程数、最大线程数、队列容量和拒绝策略例如启动一个最多 8 个线程、队列最多存 100 个任务、超时 60 秒自动回收空闲线程的池：

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    4,           // corePoolSize
    8,           // maxPoolSize
    60L,         // keepAliveTime
    TimeUnit.SECONDS,
    new ArrayBlockingQueue(100),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

submit() 和 execute() 到底该用哪个区别不在“能不能跑”，而在“要不要结果”和“异常处理方式”。

execute(Runnable)

：只负责执行，不返回任何东西，如果任务抛出未捕获异常，会直接打印到 stderr，且无法被调用方感知

submit(Runnable)

或

submit(Callable)

：返回

Future

，可主动检查状态、获取结果、等待完成；异常会被包装进

Future.get()

抛出，便于集中处理如果你需要异步计算结果（比如查数据库后聚合），必须用

submit()

Callable

常见错误：用

execute()

提交可能抛异常的任务，又没配

ThreadFactory

设置

UncaughtExceptionHandler

，导致异常静默丢失。立即学习 “ Java免费学习笔记（深入） ”； Eclipse导入Android或其他的JAVA项目的正确方法 WORD版本文档主要讲述的是Eclipse导入Android或其他的JAVA项目的正确方法；希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看下载线程池 shutdown 的正确姿势不关干净会导致 JVM 不退出，或任务被丢弃却不通知。关键不是“调 shutdown”，而是“等完再停”。先调

shutdown()

：停止接收新任务，但会继续执行已提交和队列中的任务再调

awaitTermination(long, TimeUnit)

等待执行完成，建议设合理超时（如 30 秒）如果超时仍未结束，可考虑

shutdownNow()

尝试中断正在运行的任务（注意：不是所有任务都能被中断）典型误操作：

shutdown()

后立刻 return，没等任务结束，主线程就退出了。拒绝策略选哪个才不丢任务也不卡死当线程池满 + 队列满时触发，选错会导致数据丢失或线程阻塞。四种内置策略行为差异很大：

AbortPolicy

（默认）：直接抛

RejectedExecutionException

，调用方必须处理，否则崩溃

CallerRunsPolicy

：由提交任务的线程自己执行该任务，能自然降速，适合非关键任务

DiscardPolicy

：静默丢弃，不报错，适合允许丢失的监控类任务

DiscardOldestPolicy

：丢掉队列头任务，再尝试提交当前任务，有一定风险（可能反复丢老任务）自定义策略可以记录日志、发告警、写入重试队列——但别在拒绝策略里做耗时操作（比如远程调用），会卡住

submit()

线程。

相关文章