Spring Reactor Flux，如何订阅然后阻塞直到全部完成

编程问答 2022-04-22

问题描述

Spring reactor 提供 blocklast() 如果我想同步并阻塞直到所有元素都完成

但是如果我想继续一点然后阻塞直到所有元素都完成怎么办？

（我不想使用 isdisposed 执行忙等待）

我是否需要使用由 onComplete 触发的自己的信号自己来完成，还是有更好的内置 API？

//reactor provides blocklast if I want to be synchronous and block until all elements are done
//Integer data = Flux.range(1,10).delayElements(Duration.ofSeconds(1)).doOnNext((Integer next) -> System.out.println(next + " on thread " + Thread.currentThread().getName())).blockLast();
 
//but what if I want to continue a bit and then block
//do I need to do it myself like this? is there a better way?
Object signal = new Object(); 
Flux.range(1,10).delayElements(Duration.ofSeconds(1)).doOnNext((Integer next) -> System.out.println(next + " on thread " + Thread.currentThread().getName())).doOnComplete(()->{synchronized(signal) { signal.notify();}}).subscribe();
synchronized (signal) {
    signal.wait();
}
System.out.println("All done");

解决方法

正如我在你的问题中看到的，你想要一些其他的 api 来替换 blockLast，对吗？据我所知，你必须自己实现这一点。没有用于此目的的内置 api。

javajavareactivereactorreactorreactorreactorspringspring