smallrye兵变指南说我们可以阻止miltis并反复调用:
Stream<T> stream = multi.subscribe().asStream();
stream.forEach(this::doSomethingWithItem);
操作被阻塞。我想知道你是否 stream.parallel().forEach(this::doSomethingWithItem);
将提高性能,因为任务将在 ForkJoin
游泳池。否则我会把整个 ForkJoin
池等待多个,这是不可取的?
谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!