springwebflux在多线程情况下的行为如果我像下面那样使用webflux呢
someList.parllelStream.forEach(){
if(1){
callSomeService1(latch)
}
if(2){
callSomeService2(latch)
}
}
latch.await(x ms)
callService1(latch){
Mono.subscribe{
latch.countdown
}
}
callService2(latch){
Mono.subscribe{latch.countdown}
}
我的问题是流将产生两个线程,这两个线程将有2个订户,这两个线程稍后将完成,并且闩锁将等待自己倒计时。在最后有两个订阅者,并且起始线程在闩锁上等待,这种方法正确吗?
暂无答案!
目前还没有任何答案,快来回答吧!