孤舟笔记 并发篇二十四 线程池如何知道一个线程的任务已经执行完成？三种方式各有乾坤

文章目录一、先说结论感知任务完成的三种方式二、方式一Future.get()三、方式二CompletionService四、方式三CountDownLatch五、方式四FutureTask 回调六、对比总结感知任务完成方式全景回答技巧与点评标准回答加分回答面试官点评个人网站你提交了一堆任务到线程池想等它们全部完成再往下走怎么搞或者你想知道某个任务执行完了没有拿没拿到结果这些场景都涉及线程池怎么感知任务完成。面试官问这个问题不只是考 API更是考你对 Future、CompletionService 这些工具的理解深度。一、先说结论感知任务完成的三种方式方式适用场景特点Future.get()等待单个任务完成阻塞等待可获取结果CompletionService批量任务按完成顺序获取先完成的先拿到CountDownLatch批量任务等待全部完成不关心结果只等全部做完invokeAll()批量任务等待全部完成返回所有 FutureisTerminated()线程池关闭后判断需先 shutdown()一句话记住单个任务用 Future批量按序用 CompletionService批量等完用 CountDownLatch——工具选对事半功倍。二、方式一Future.get()最基本的方式——提交任务时拿到 Future调用 get() 阻塞等待ExecutorServicepoolExecutors.newFixedThreadPool(3);FutureStringfuturepool.submit(()-{Thread.sleep(2000);return任务结果;});// 阻塞等待直到任务完成Stringresultfuture.get();// 最多等多久一直等System.out.println(result);// 带超时的等待Stringresult2future.get(5,TimeUnit.SECONDS);// 5秒超时问题如果提交了多个任务逐个 get() 是串行等待的ListFutureStringfuturesnewArrayList();for(inti0;i5;i){futures.add(pool.submit(()-doTask()));}// ❌ 问题如果第一个任务最慢后面快的也得等for(FutureStringf:futures){System.out.println(f.get());// 串行阻塞 }生活类比你去医院取五个检查报告挨个窗口等——哪怕第二个报告早出了你也得先等第一个。三、方式二CompletionServiceCompletionService 解决了串行等待的问题——谁先完成谁先拿到ExecutorServicepoolExecutors.newFixedThreadPool(3);CompletionServiceStringcsnewExecutorCompletionService(pool);// 提交 5 个任务for(inti0;i5;i){finalintidxi;cs.submit(()-doTask(idx));}// 按完成顺序获取结果for(inti0;i5;i){FutureStringfcs.take();// 取一个已完成的 Future阻塞System.out.println(f.get());// 立刻获取结果不阻塞}原理CompletionService 内部维护了一个BlockingQueueFuture任务完成后 Future 自动入队。take() 从队列取谁先完成谁先进队列。生活类比五个人同时做饭谁先做好谁先端上来——不用等最慢的那道菜。经典应用从多个搜索引擎取结果谁先返回就用谁CompletionServiceStringcsnewExecutorCompletionService(pool);cs.submit(()-searchBaidu(keyword));cs.submit(()-searchGoogle(keyword));cs.submit(()-searchBing(keyword));// 谁先返回就用谁Stringresultcs.take().get();四、方式三CountDownLatch如果你不关心结果只关心全部做完用 CountDownLatchinttaskCount10;CountDownLatchlatchnewCountDownLatch(taskCount);for(inti0;itaskCount;i){pool.submit(()-{try{doTask();}finally{latch.countDown();// 每完成一个计数器 -1}});}latch.await();// 阻塞等待直到计数器归零System.out.println(所有任务执行完毕);生活类比10 个工人在干活你在大门口数人头——最后一个回来了关门下班。vs invokeAll()// invokeAll 也能等全部完成ListFutureStringfuturespool.invokeAll(tasks);// 阻塞等所有任务完成for(FutureStringf:futures){System.out.println(f.get());}区别invokeAll 返回所有 Future可以拿结果CountDownLatch 更轻量只做同步。五、方式四FutureTask 回调Java 8 可以用 CompletableFuture 实现回调式通知CompletableFuture.supplyAsync(()-doTask(),pool).thenAccept(result-{System.out.println(任务完成结果: result);// 回调不阻塞});// 主线程继续做其他事...优势不阻塞等待任务完成后自动回调。这是最现代的方式。六、对比总结方式阻塞获取结果批量按序Future.get()阻塞✅❌ 串行等CompletionService阻塞✅✅ 先完成先取CountDownLatch阻塞❌等全部完成invokeAll()阻塞✅等全部完成CompletableFuture非阻塞回调✅✅ 任意组合感知任务完成方式全景感知任务完成 全景 单个任务 └── Future.get() ── 阻塞等待结果 批量任务 ├── CompletionService ── 按完成顺序取先完先得 ├── CountDownLatch ── 只等全部完成不管结果 ├── invokeAll() ── 等全部完成返回所有 Future └── CompletableFuture ── 回调式非阻塞 选择策略 ├── 要结果、单个任务 → Future.get() ├── 要结果、批量按序 → CompletionService ├── 不要结果、只等完成 → CountDownLatch └── 不想阻塞 → CompletableFuture 口诀Future 等单个Completion 按序取 Latch 等全部Completable 回调走 阻塞非阻塞各有所长场景选对是关键。回答技巧与点评标准回答线程池感知任务完成有几种方式一是通过 Future.get() 阻塞等待单个任务完成并获取结果二是用 CompletionService 批量提交任务按完成顺序获取结果先完成先拿到三是用 CountDownLatch 等待所有任务完成不关心结果四是用 CompletableFuture 实现非阻塞的回调式通知。其中 CompletionService 解决了 Future.get() 串行等待的问题CompletableFuture 是最现代的异步编程方式。加分回答CompletionService 的原理它内部维护了一个 BlockingQueueFuture把 Executor 和 BlockingQueue 组合在一起。任务完成后ExecutorCompletionService 会把 Future 封装成 QueueingFuture覆盖了 done() 方法任务完成时自动入队。这是生产者-消费者模式的精巧应用Future.get() 的超时陷阱get(timeout) 超时后只是抛 TimeoutException任务仍在后台执行。如果需要真正取消任务应该 catch 超时后调用 future.cancel(true)CompletableFuture 的优势它不仅支持 thenAccept 回调还支持 thenCombine合并两个结果、thenCompose链式异步、allOf等全部、anyOf任一完成等丰富的组合操作是 Java 异步编程的首选面试官点评这道题考的是你对并发工具链的全面掌握。能说出 Future 和 CountDownLatch 是基本要求能讲清 CompletionService 按完成顺序获取的原理、以及 CompletableFuture 的回调优势才说明你有过批量任务处理的实战经验。面试官最想听到的是你不仅知道有哪些方式还能根据场景做出正确的选择。原文阅读内容有帮助点赞、收藏、关注三连评论区等你