博客

JDK8中的CompletionService实际上可以看做是Executor和BlockingQueue的结合体。CompletionService在接收到要执行的任务时，通过类似BlockingQueue的put和take获得任务执行的结果。CompletionService的一个实现是ExecutorCompletionService，ExecutorCompletionService把具体的计算任务交给Executor完成。

hutool中进行了封装

package com.fayi.hutool;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.TimeInterval;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;

import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class TheadUtil {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        TimeInterval timer = DateUtil.timer();
        // 新建一个CompletionService，调用其submit方法可以异步执行多个任务
        // 最后调用take方法按照完成的顺序获得其结果
        // 使用的是全局公共线程池，此线程池是一个无限线程池，即加入的线程不等待任何线程，直接执行
        CompletionService<String> cs = ThreadUtil.newCompletionService();
        Future<String> submit1 = cs.submit(() -> getString1());
        Future<String> submit2 = cs.submit(() -> getString2());
        Future<String> submit3 = cs.submit(() -> getString3());
        System.out.println(submit1.get());
        System.out.println(submit2.get());
        System.out.println(submit3.get());
        System.out.println(StrUtil.format("并行获取结果一共执行了{}ms",timer.interval()));
    }

    private static String getString1() {
        ThreadUtil.sleep(1000);
        return "1";
    }

    private static String getString2() {
        ThreadUtil.sleep(2000);
        return "2";
    }

    private static String getString3() {
        ThreadUtil.sleep(3000);
        return "3";
    }
}