迭代multi的项:stream与parallelstream

oaxa6hgo  于 2021-06-30  发布在  Java
关注(0)|答案(0)|浏览(222)

smallrye兵变指南说我们可以阻止miltis并反复调用:

Stream<T> stream = multi.subscribe().asStream();
stream.forEach(this::doSomethingWithItem);

操作被阻塞。我想知道你是否 stream.parallel().forEach(this::doSomethingWithItem); 将提高性能,因为任务将在 ForkJoin 游泳池。否则我会把整个 ForkJoin 池等待多个,这是不可取的?
谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题