当前位置：首页 > news >正文

Java 线程池核心原理：Worker 线程复用机制

news 2026/5/28 10:07:24

大家好，本篇我们来彻底讲透线程池最核心、最灵魂、面试最常问的知识点：线程池是如何实现线程复用的？

很多同学会用线程池，会写ThreadPoolExecutor，也知道 7 大参数，但你一旦被问：线程执行完任务，为什么不销毁？为什么能接着执行下一个任务？大部分人就答不上来了。

答案只有一个：因为线程池的线程，根本不是普通 Thread，而是 Worker！

本篇从原理到流程，再到源码逻辑，用最通俗的方式讲清楚，让你彻底理解线程池的 “心脏”。

一、先搞懂：线程复用到底是什么意思？

我们先看不用线程池的情况：

new Thread(() -> { // 任务执行 }).start();

执行完 → 线程销毁。再来任务 → 再新建线程。创建 → 销毁 → 创建 → 销毁…开销巨大。

线程池的线程复用：

线程执行完一个任务
不销毁
等着取下一个任务
继续执行
一直循环…

这就是线程复用。

那它是怎么做到不销毁、一直取任务的？答案：Worker + 循环从阻塞队列 getTask ()

二、线程池的真正工作者：Worker 是什么？

ThreadPoolExecutor里面有一个内部类 Worker。

它是线程池的 “工人”，源码结构如下：

private final class Worker extends AbstractQueuedSynchronizer implements Runnable { final Thread thread; // 真正执行任务的线程 Runnable firstTask; // 第一个任务 Worker(Runnable firstTask) { this.firstTask = firstTask; this.thread = getThreadFactory().newThread(this); } public void run() { runWorker(this); // 真正执行逻辑 } }

关键点：

Worker 本身是一个 Runnable
它内部持有一个真正的Thread
线程池的线程，都是 Worker 里面的 thread
线程复用，就是 Worker 在复用

一句话：线程池 = 一堆 Worker 在不停循环干活。

三、最核心方法：runWorker ( ) —— 线程复用的灵魂

线程池线程不销毁、能复用，全靠这个方法：

final void runWorker(Worker w) { Runnable task = w.firstTask; w.firstTask = null; // 死循环！！！ while (task != null || (task = getTask()) != null) { // 执行任务 task.run(); // 执行完，置空，继续循环 task = null; } }

看到了吗？一个 while 循环，永远不退出！

流程：

先执行第一个任务
执行完 → 调用getTask()去队列拿新任务
拿到 → 继续执行
再执行完 → 再去队列拿
循环…

这就是线程复用的本质！

线程不是执行完就死，而是一直循环从队列取任务执行。

四、getTask () ：任务从哪来？

getTask()是决定线程 “什么时候活着、什么时候死亡” 的方法。

它做两件事：

从阻塞队列 take /poll 任务
控制核心线程 / 非核心线程的存活策略

简化逻辑：

private Runnable getTask() { if (线程是核心线程 || 没超时) { // 一直阻塞等任务 return workQueue.take(); } else { // 非核心线程：超时就返回null → 线程退出 return workQueue.poll(keepAliveTime, unit); } }