springboot 线程池并行化处理如何保证全部执行完获得结果

在Spring Boot中，可以使用Java线程池来实现并行化处理，并且可以通过CompletableFuture的一些方法等待异步方法执行完毕，并获取结果。

具体来说，可以使用CompletableFuture的join()方法等待所有异步方法执行完毕，并返回结果。join()方法会阻塞当前线程，直到所有异步方法都执行完毕并返回结果。如果其中任意一个异步方法抛出异常，则join()方法也会抛出相应的异常。

示例代码如下：

// 1. 在需要并行化处理的方法上添加@Async注解
@Service
public class MyService {

    @Async
    public CompletableFuture<String> doSomethingAsync(int index) {
        // 需要异步执行的方法
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("done-" + index);
    }

}

// 2. 调用需要并行化处理的方法，并等待所有异步方法执行完毕
@RestController
public class MyController {

    @Autowired
    private MyService myService;

    @GetMapping("/async")
    public List<String> async() throws InterruptedException {
        List<CompletableFuture<String>> futures = new ArrayList<>();
        // 调用10次异步方法
        for (int i = 0; i < 10; i++) {
            futures.add(myService.doSomethingAsync(i));
        }
        // 等待所有异步方法执行完毕，并返回结果
        return futures.stream().map(CompletableFuture::join).collect(Collectors.toList());
    }

}

在上面的示例代码中，我们调用了10次异步方法，并使用join()方法等待所有异步方法执行完毕，并返回结果。最终返回的结果是一个包含10个字符串的列表，分别表示每个异步方法的执行结果。

需要注意的是，join()方法会阻塞当前线程，如果异步方法的执行时间过长，可能会导致线程阻塞时间过长，影响系统的性能。因此，在实际应用中，需要根据具体情况合理地设置异步方法的执行时间和线程池的大小。