孤舟笔记 并发篇二十三 线程池是如何实现线程复用的？Worker循环取任务的秘密远比你想象的精巧

文章目录一、先说结论线程复用的核心机制二、Worker线程和任务的合体三、runWorker()复用的核心循环四、getTask()从队列取下一个任务五、完整流程从提交到复用六、对比不使用线程池 vs 使用线程池线程复用机制全景回答技巧与点评标准回答加分回答面试官点评个人网站每个 Thread 只能 start 一次那线程池怎么做到复用线程的一个线程执行完任务为什么没有退出它是怎么拿到下一个任务的搞不懂线程复用的原理线程池对你来说就是黑盒。今天咱们拆开看看。一、先说结论线程复用的核心机制维度说明核心思路Worker 线程在 while 循环中反复取任务取到就执行取不到就等关键代码runWorker() 中的 while (task ! null || (task getTask()) ! null)Worker 本质继承 AQS既是线程又是任务载体首次任务Worker 创建时绑定 firstTask先执行它后续任务firstTask 执行完后从 workQueue 中取等待机制核心线程用 take() 永久阻塞非核心线程用 poll() 超时等待一句话记住线程复用就像流水线工人——干完一个零件不是下班而是伸手拿下一个没零件就等着永远不会自己走。二、Worker线程和任务的合体Worker 是 ThreadPoolExecutor 的内部类它同时继承了 AQS 并实现了 RunnableprivatefinalclassWorkerextendsAQSimplementsRunnable{finalThreadthread;// Worker 对应的线程 RunnablefirstTask;// 第一个任务可能为 null volatilelongcompletedTasks;Worker(RunnablefirstTask){setState(-1);// 禁止在 runWorker 前被中断this.firstTaskfirstTask;this.threadgetThreadFactory().newThread(this);// 用自己创建线程 }publicvoidrun(){runWorker(this);// 线程启动后执行 runWorker }}关键Worker 本身就是 Runnablethread 的 run() 方法执行的就是 Worker.run() → runWorker()。线程启动后就进入了 runWorker 的循环。三、runWorker()复用的核心循环finalvoidrunWorker(Workerw){ThreadwtThread.currentThread();Runnabletaskw.firstTask;// 先拿第一个任务 w.firstTasknull;w.unlock();// 允许被中断try{while(task!null||(taskgetTask())!null){// 核心循环w.lock();// 执行任务时加锁防止 shutdown 同时中断// 检查线程池状态if((runStateAtLeast(ctl.get(),STOP)||(Thread.interrupted()runStateAtLeast(ctl.get(),STOP)))!wt.isInterrupted())wt.interrupt();try{beforeExecute(wt,task);// 钩子方法try{task.run();// 执行任务}catch(Throwablex){afterExecute(task,x);// 钩子方法throwx;}finally{afterExecute(task,null);// 钩子方法}}finally{tasknull;// 清空下一轮从队列取 w.completedTasks;w.unlock();}}}finally{processWorkerExit(w,false);// 线程退出 }}复用的秘密全在 while 循环首次执行 Worker 绑定的 firstTask后续task getTask()从队列取取到了 → 执行 → task 置 null → 下一轮继续取取不到 → 循环退出 → 线程终止线程没有退出是因为 while 循环没结束。这就是复用的本质。四、getTask()从队列取下一个任务privateRunnablegetTask(){booleantimedOutfalse;for(;;){// ... 状态检查 ...booleantimedallowCoreThreadTimeOut||wccorePoolSize;try{Runnablertimed?workQueue.poll(keepAliveTime,TimeUnit.NANOSECONDS):// 限时等 workQueue.take();// 永久等 if(r!null)returnr;timedOuttrue;}catch(InterruptedExceptionretry){timedOutfalse;}}}场景取任务方式行为核心线程take()队列空时永久阻塞直到有任务非核心线程poll(keepAliveTime)队列空时等待 keepAliveTime超时返回 null队列有任务poll/take 立即返回拿到任务继续执行生活类比核心线程是正式员工在工位上一直等take非核心线程是临时工等了 keepAliveTime 还没事干就下班了poll 超时。五、完整流程从提交到复用提交任务 submit(task) │ ├─ workerCount corePoolSize │ └─ 是 → addWorker(task, true) → 创建 Worker绑定 firstTask │ ├─ workQueue.offer(task) │ └─ 是 → 任务入队等待空闲 Worker 来取 │ └─ 否 → addWorker(task, false) → 创建非核心 Worker Worker 生命周期 │ start() → run() → runWorker() │ while 循环 ├─ 执行 firstTask第一次 ├─ getTask() 从队列取后续 复用的关键 ├─ 取到 → task.run() ├─ 取不到 → 循环退出 → processWorkerExit() └─ 线程终止六、对比不使用线程池 vs 使用线程池// 不用线程池每个任务一个线程执行完就销毁for(inti0;i1000;i){newThread(task).start();// 创建1000个线程用完即销毁 }// 线程池10个线程循环执行1000个任务ExecutorServicepoolExecutors.newFixedThreadPool(10);for(inti0;i1000;i){pool.submit(task);// 10个Worker循环取任务复用线程 }节省了 990 个线程的创建和销毁开销。线程复用机制全景线程复用 全景 核心原理 Worker 线程在 while 循环中反复取任务 ├── firstTask → 首次执行 ├── getTask() → 后续从队列取 └── 循环退出 → 线程终止不再复用 关键方法 ├── runWorker() ── while 循环取任务并执行 ├── getTask() ── 从 workQueue 获取任务 │ ├── take() ── 核心线程永久等 │ └── poll(timeout) ── 非核心线程限时等 └── processWorkerExit() ── 线程退出善后 Worker 设计 ├── extends AQS ── 实现不可重入锁标记线程是否在执行任务 ├── implements Runnable ── 本身是可执行体 └── thread new Thread(this) ── 用自己创建线程 口诀Worker 是循环工firstTask 先干完 getTask 从队列取取到就干取不到等 核心永远等非核心限时等 while 循环不停歇线程复用自然成。回答技巧与点评标准回答线程池通过 Worker 线程的 while 循环实现线程复用。Worker 继承 AQS 并实现 Runnable创建时绑定一个 firstTask。线程启动后执行 runWorker()在 while 循环中先执行 firstTask然后不断通过 getTask() 从 workQueue 获取下一个任务。核心线程使用 take() 永久阻塞等待非核心线程使用 poll(keepAliveTime) 限时等待。只要 getTask() 能取到任务线程就不会退出从而实现复用。加分回答Worker 的 AQS 锁设计Worker 继承 AQS 实现了不可重入的互斥锁用于标记线程是否正在执行任务。shutdown() 时只中断空闲线程锁未被占用不中断正在执行任务的线程。不可重入是为了防止任务代码中调用 shutdown() 时误判线程状态beforeExecute/afterExecute 钩子runWorker() 在任务执行前后留了钩子方法子类可以覆盖来实现监控、统计、日志等功能。这是模板方法模式的体现线程复用 vs 对象池线程池的复用不是对象池那种借还模式而是循环取任务模式。线程始终持有运行权只是在不同任务之间切换。这种设计更高效避免了线程的频繁创建和上下文切换面试官点评这道题考的是你对线程池内部运作机制的深入理解。能说出while 循环取任务是核心但能讲清 Worker 的设计AQS 锁、firstTask、getTask 的区别、核心线程和非核心线程的不同等待策略、以及 beforeExecute/afterExecute 钩子的作用才说明你真的读过源码。面试官最想听到的核心认知是线程复用的本质不是线程被回收再分配而是线程一直在循环中跑只是执行的任务在变。原文阅读内容有帮助点赞、收藏、关注三连评论区等你