前言
在工作中是否存在这样的场景，多个线程提交执行，你不想全部线程执行结束了获取结果，而是有线程完成返回结果就获取消费。本文提供该场景的工具类，可以直接用哦。
Maven依赖
其实要不要无所谓。主要是为了方便。
<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.15</version> </dependency>
代码
不废话，上代码。
package com.hy.csdn.tools; import cn.hutool.core.thread.ThreadUtil; import java.util.Arrays; import java.util.List; import java.util.concurrent.*; import java.util.function.Consumer; /** * @author huyi * @date 2021/11/1 下午2:22 */ public class ThreadPriorityUtil { private static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(100); /** * 提交多个任务 * @param tasks 任务 * @param consumer 结果消费 * @param <T> 泛型 */ public static <T> void submit(List<Callable<T>> tasks, Consumer<T> consumer) { CompletionService<T> completionService = new ExecutorCompletionService<>(EXECUTOR_SERVICE); tasks.forEach(completionService::submit); tasks.forEach( x -> { try { consumer.accept(completionService.take().get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }); } public static void destroy() { System.out.println("摧毁线程池"); EXECUTOR_SERVICE.shutdown(); } public static void main(String[] args) { // 启动3个线程执行试试看 List<Callable<Integer>> tasks = Arrays.asList( () -> { try { TimeUnit.SECONDS.sleep(30); System.out.println("task 30 completed"); } catch (InterruptedException e) { e.printStackTrace(); } return 30; }, () -> { try { TimeUnit.SECONDS.sleep(10); System.out.println("task 10 completed"); } catch (InterruptedException e) { e.printStackTrace(); } return 10; }, () -> { try { TimeUnit.SECONDS.sleep(20); System.out.println("task 20 completed"); } catch (InterruptedException e) { e.printStackTrace(); } return 20; }); ThreadPriorityUtil.submit(tasks, x -> System.out.println("回调结果：" + x)); ThreadUtil.sleep(40000L); ThreadPriorityUtil.destroy(); } }
执行看看
OK，先执行结束的线程，先消费。
总结
一个姑娘，如果有被人喜欢，而且那个人喜欢的干干净净，怎么都是一件美好的事情。
如果本文对你有帮助的话，不要吝啬你的赞，狠狠的甩给我。
