Maven依賴

其實(shí)要不要無所謂。主要是為了方便。

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

  /**
   * 提交多個(gè)任務(wù)
   * @param tasks 任務(wù)
   * @param consumer 結(jié)果消費(fèi)
   * @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) {
  // 啟動(dòng)3個(gè)線程執(zhí)行試試看
  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("回調(diào)結(jié)果：" + x));

  ThreadUtil.sleep(40000L);
  ThreadPriorityUtil.destroy();
}
}

執(zhí)行看看

OK，先執(zhí)行結(jié)束的線程，先消費(fèi)。

總結(jié)

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

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

到此這篇關(guān)于Java多線程提交按照時(shí)間順序獲取線程結(jié)果詳解流程的文章就介紹到這了,更多相關(guān)Java 多線程內(nèi)容請(qǐng)搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家！

原文鏈接：https://huyi-aliang.blog.csdn.net/article/details/121089542