如何解决Spring Reactor Flux,如何订阅然后阻塞直到全部完成
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。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。