如何在可观察到的“时间后重置”中修复竞争条件？

Question

Input 是一个 observable，每次出现问题时都会产生一个值。

作为输出，我想要一个 observable，如果问题存在更长时间，它会产生一个值。换句话说，如果最后一个问题已经过时，我想“重置”输出 observable（不产生值）。

我的解决方案：

// first get an observable producing statusOk values (true = ok, false = not ok)
var okStatusObservable = input.Select(_ => true).Throttle(longerTime)
                  .Merge(input.Select(_ => false));


// we only want event if statusOk=false for a longer time
var outputObservable = okStatusObservable
                  .DistinctUntilChanged() // only changes
                  .Throttle(evenLongerTime) // wait for stable status
                  .Where(_ => _ == false); // only interested in bad status

我认为okStatusObservable 可能包含竞争条件：如果输入以恰好longerTime 的时间间隔接收事件，并且第二个合并部分（Select / false）将在第一部分（@ 987654326@+Throttle / true) 那么这将导致 okStatus 为 true 99.9% 的时间正好相反。

（PS：要从一开始就有状态值，我们可能会添加.StartWith(true)，但这对于竞争条件无关紧要。）

Answer 1

执行第一个 observable 的更简洁的方法如下：

var okStatusObservable2 = input
    .Select(_ => Observable.Return(true).Delay(longerTime).StartWith(false))
    .Switch();

解释：对于每条input 消息，产生一个以 false 开头的 observable，longerTime 之后产生一个 true。 Switch 意味着如果你有一个新的 observable，只需切换到它，这将排除最后的全部清除 true。

对于您的第二个 observable，除非两个 observable 之间的 longerTime 不同，否则第一个 observable 中的每个第一个 false 都会在第二个 observable 中产生一个 false。这是你的意图吗？

另外，您的 Where 搞砸了（应该是 .Where(b => !b) 或 .Where(b => b == false)。.Where(_ => false) 将始终评估为 false 不返回任何内容。

除此之外，我认为您的解决方案是合理的。