本文介绍了Mono链的Webflow超时的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我正在使用Spring Webflow,并尝试理解Monos链的超时概念。

例如,有一系列Mono调用:

myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)

如何应用超时:

1)一般操作(操作总时间)

2)用于ECH操作(每次操作不应超过超时)

3)仅用于最后一次操作(n操作)

我几乎可以肯定,超时适用于最后一个发布者。如果是,如何将超时应用于操作总数?

推荐答案

超时运算符测量从订阅时间到超时运算符观察到的onNext/onComplete信号之间经过的时间。

考虑以下示例:

Mono.delay(Duration.ofMillis(1000))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .timeout(Duration.ofMillis(2500))
    .block();

如果语句2(两次操作之间测量的时间)或3(仅上次操作的持续时间计数)正确,则上面的代码不会引发任何错误。

但是,超时操作测量的是上游所有操作的持续时间,因此语句1(测量的所有操作的总和)是正确的

在本例中,所有操作的总和(1000+1000+1000=3000ms)大于配置的超时时间(2500ms),因此代码会导致错误。

这篇关于Mono链的Webflow超时的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

09-05 10:34