java使用多线程并行处理逻辑后合并处理结果（Java多线程ExecutorService方式）

本文主要是介绍java使用多线程并行处理逻辑后合并处理结果（Java多线程ExecutorService方式），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. 需求描述

业务逻辑中有时候需要使用多线程去分别执行不同的方法，然后将所有方法的返回结果进行合并，即并行调用若干方法，然后将若干方法各自的返回结果做下一步处理的场景。

2. 使用Java多线程实现（本质上是ExecutorService方式）

package xxx;import com.google.common.collect.Lists;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.scheduling.annotation.Async;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
import java.util.stream.Collectors;@SpringBootTest
public class AsyncTest {@Testvoid test() {//使用ExecutorService方式ExecutorService executorService = Executors.newFixedThreadPool(3);//计数器CountDownLatch countDownLatch = new CountDownLatch(3);//假如有3个方法，各自需要1s 5s 10s 然后返回1 2 3Future<String> future1 = executorService.submit(() -> {try{//这里其实就可以写Service的某个方法，让其异步执行即可Thread.sleep(1000);return "1";}finally {countDownLatch.countDown();}});Future<String> future2 = executorService.submit(() -> {try{//这里其实就可以写Service的某个方法，让其异步执行即可Thread.sleep(5000);return "2";}finally {countDownLatch.countDown();}});Future<String> future3 = executorService.submit(() -> {try{//这里其实就可以写Service的某个方法，让其异步执行即可Thread.sleep(10000);return "3";}finally {countDownLatch.countDown();}});countDownLatch.await();System.out.println(future1.get());System.out.println(future2.get());System.out.println(future3.get());long end = System.currentTimeMillis();System.out.println("耗时："+(end-start));}
}