Java多线程提交按照时间顺序获取线程结果详解流程 Java多线程提交按照时间顺序获

Maven依赖其实要不要无所谓。主要是为了方便。

cn.hutoolhutool-all5.7.15

代码不废话，上代码。

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 泛型*/public static void submit(List> tasks, Consumer consumer) {CompletionService 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> 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(); }}

执行看看