多螺纹情况下Spring腹板流量的特性

kyxcudwk  于 2021-07-23  发布在  Java
关注(0)|答案(0)|浏览(164)

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个订户,这两个线程稍后将完成,并且闩锁将等待自己倒计时。在最后有两个订阅者,并且起始线程在闩锁上等待,这种方法正确吗?

暂无答案!

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

相关问题