ExecutorCompletionService是包装ExecutorService的工具类，利用BlockingQueue存储已完成任务的Future，通过take()或poll()按完成顺序获取结果，实现“谁先完成，谁先处理”。创建时需传入ExecutorService实例，提交任务后可用take()阻塞等待或poll()非阻塞获取结果，适用于搜索、爬虫等需尽早响应的场景，使用后记得关闭线程池。
在Java中，当你需要提交多个任务并希望按照任务完成的顺序来处理结果时，ExecutorCompletionService 是一个非常实用的工具。它结合了 ExecutorService 和 BlockingQueue 的优势，能够将已完成的任务结果放入队列中，让你可以逐个获取最先完成的任务结果，而不需要等待所有任务都结束。
什么是ExecutorCompletionService？
它是一个包装了 ExecutorService 的服务类，内部使用一个 BlockingQueue 来存放已完成的 Future 对象。每当你调用 take() 或 poll() 方法时，就能获取第一个完成的任务的 Future，实现“谁先完成，谁先处理”。
基本使用步骤
要使用 ExecutorCompletionService，可以按以下方式操作：
创建一个 ExecutorService 实例（如 ThreadPoolExecutor）用该实例初始化 ExecutorCompletionService通过 submit() 提交多个 Callable 或 Runnable 任务使用 take() 或 poll() 获取已完成任务的结果
代码示例：处理多个耗时任务
假设你有5个任务，每个任务执行时间不同，你想尽快处理每一个完成的任务：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.*;public class CompletionServiceExample {public static void main(String[] args) {ExecutorService executor = Executors.newFixedThreadPool(3);ExecutorCompletionService completionService = new ExecutorCompletionService(executor);
// 提交5个任务 for (int i = 1; i { long sleepTime = (long) (Math.random() * 5000); // 随机睡眠 Thread.sleep(sleepTime); System.out.println("任务 " + taskId + " 完成，耗时: " + sleepTime + "ms"); return sleepTime; }); } // 按完成顺序处理结果 for (int i = 0; i < 5; i++) { try { Integer result = completionService.take().get(); // take()阻塞直到有任务完成 System.out.println("处理完成结果: " + result + "ms"); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } executor.shutdown();}}
易森网络企业版
如果您是新用户，请直接将本程序的所有文件上传在任一文件夹下，Rewrite 目录下放置了伪静态规则和筛选器，可将规则添加进IIS，即可正常使用，不用进行任何设置；(可修改图片等)默认的管理员用户名、密码和验证码都是：yeesen系统默认关闭，请上传后登陆后台点击“核心管理”里操作如下:进入“配置管理”中的&ld
0 查看详情
在这个例子中，虽然任务是按顺序提交的，但输出会根据实际完成时间排序。最先完成的任务结果会被最先处理。
take() 与 poll() 的区别
两者都用于获取已完成任务的 Future，但行为不同：
take()：阻塞方法，如果没有完成的任务，会一直等待直到有一个任务完成poll()：非阻塞方法，立即返回结果；如果没有完成任务，返回 null。也可以设置超时时间
例如，使用带超时的 poll：
Future future = completionService.poll(1, TimeUnit.SECONDS);if (future != null) { Integer result = future.get(); System.out.println("获取到结果: " + result);} else { System.out.println("1秒内无任务完成");}这在需要控制响应时间或做阶段性检查时很有用。
基本上就这些。使用
ExecutorCompletionService能有效提升并发任务处理效率，特别适合搜索、爬虫、批量请求等场景，哪里需要“尽早响应”而不是“等待全部”。不复杂但容易忽略的是，别忘了关闭线程池。以上就是如何在Java中使用ExecutorCompletionService处理任务的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/739790.html
微信扫一扫 
支付宝扫一扫 
