小编sha*_*gur的帖子

我的情况很简单.

我有一个列表,我想异步地对每个项目执行逻辑.

当所有线程都完成后,我想调用一个紧密的连接.

像这样:

bucketsList.parallelStream().forEach(t -> {
//some logic
});
 try {
 RestApi.getInstance().closeClientConnection();
 } catch (IOException e) {
     e.printStackTrace();
 }

有没有办法让closeConnection部分等待并行Stream完成遍历所有对象？

编辑:我不能使用,CountDownLatch因为我不知道我将在bucketsList中有多少项目