带队列的 Java 流

问题描述

我正在寻找是否可以将 Java 流与队列/背压一起使用。 类似的东西:

iterator -> (queue?) -> parallelstream -> map -> collector

映射比迭代器慢(即使是多线程的),所以迭代器的读取速度应该更慢(背压)或者来自迭代器的数据应该排队等待映射。 我发现反应流可用于背压 (https://blog.softwaremill.com/how-not-to-use-reactive-streams-in-java-9-7a39ea9c2cb3) 但队列呢?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)