代码之家 › 专栏 › 技术社区 › sharon gur

java 8并行流,是否可能阻塞代码?

java-stream asynchronous java

sharon gur · 技术社区 · 8 年前

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

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

像这样:

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

编辑: 我不能使用 CountDownLatch

1 回复 | 直到 8 年前

Aaron 8 年前

在上的操作 ParallelStream 仍在阻塞,将等待生成的所有线程完成。这些线程是异步执行的(它们不等待前一个线程完成),但这并不意味着整个代码开始异步运行!

CompletableFuture<T> 在你的 forEach reduce 可完成的未来<T> .中间操作可以是 peek map 有副作用(两者都不被看好,但我不知道有什么最佳解决方案)。解决单个结果后,您将关闭连接 .

closeClientConnection() 并行流 已处理。

推荐文章

Niobos · 如何/是否有方法使通用算法函数同时与同步和异步函数一起工作?

1 年前

Rami Dhouib · Flutter:如果等待时间超过2秒,则执行操作

1 年前

Jess The Witch · GCP云功能中处理延迟任务的模式

1 年前

justiceorjustus · Javascript中异步递归函数块内部是否有同步函数调用?

1 年前

Plup · 连接失败时,PyMongo异步客户端未引发异常

1 年前

user1233894 · 尝试从全局函数传递值

1 年前

ZNackasha · 如何将Arc<RwLock<dyn Child>>转换为Arc<RwLock<dyn-Base>>

1 年前

Grigory Turlykin · 发送媒体python电报机器人(ASYNC)

1 年前

Fabiano Taioli · 管理单线程Rust中的阻塞函数

1 年前

river7816 · 为什么spdlog不在async函数中打印

1 年前