前言

在作業中是否存在這樣的場景，多個執行緒提交執行，你不想全部執行緒執行結束了獲取結果，而是有執行緒完成回傳結果就獲取消費，本文提供該場景的工具類，可以直接用哦，

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，先執行結束的執行緒，先消費，

總結

一個姑娘，如果有被人喜歡，而且那個人喜歡的干干凈凈，怎么都是一件美好的事情，

如果本文對你有幫助的話，不要吝嗇你的贊，狠狠的甩給我，

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/344211.html

標籤：java

上一篇：無法編譯示例bpf程式，缺少bpf/bpf.h

下一篇：【Java】通訊錄管理系統小專案

java多執行緒提交，如何按照時間順序獲取執行緒結果，看完你就懂了 ｜ Java工具類

前言

Maven依賴

代碼

總結

java多執行緒提交，如何按照時間順序獲取執行緒結果，看完你就懂了｜ Java工具類