jjzjj

ParallelExample

全部标签

java - StreamEx.parallel().forEach() 在 .map() 之后不并行运行

我注意到,如果我使用StreamEx库通过自定义ForkJoinPool并行处理我的流,如下所示-后续操作会在该池的并行线程中运行。但是,如果我添加一个map()操作并并行生成流-仅使用池中的一个线程。下面是演示此问题的最小工作示例的完整代码(没有所有导入)。executeAsParallelFromList()和executeAsParallelAfterMap()方法之间的唯一区别是在.parallel()之前添加了.map(...)调用。importone.util.streamex.StreamEx;publicclassParallelExample{privatestati