目录

前言

Maven依赖

代码

总结

前言

在工作中是否存在这样的场景，多个线程提交执行，你不想全部线程执行结束了获取结果，而是有线程完成返回结果就获取消费。本文提供该场景的工具类，可以直接用哦。

Maven依赖

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

        
            cn.hutool
            hutool-all
            5.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;


public class ThreadPriorityUtil {
  private static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(100);

    
  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();
  }
}

执行看看

OK，先执行结束的线程，先消费。

总结

一个姑娘，如果有被人喜欢，而且那个人喜欢的干干净净，怎么都是一件美好的事情。

如果本文对你有帮助的话，不要吝啬你的赞，狠狠的甩给我。