确保 Polly 策略至少运行一次

Question

所以，我正在编写一些使用 Polly 获取锁的重试逻辑。整体超时值将由 API 调用者提供。我知道我可以在整体超时中包装策略。但是，如果提供的超时值太低，是否有办法确保策略至少执行一次？

显然我可以在执行策略之前单独调用委托，但我只是想知道是否有办法在 Polly 中表达此要求。

var result = Policy.Timeout(timeoutFromApiCaller)
                    .Wrap(Policy.HandleResult(false)
                                .WaitAndRetryForever(_ => TimeSpan.FromMilliseconds(500))
                    .Execute(() => this.TryEnterLock());

如果 timeoutFromApiCaller 是 1 tick 并且很有可能需要更长的时间才能达到超时策略，则不会调用委托（该策略将超时并抛出 TimeoutRejectedException）。

我希望发生的事情可以表达为：

var result = this.TryEnterLock();

if (!result)
{
    result = Policy.Timeout(timeoutFromApiCaller)
                   .Wrap(Policy.HandleResult(false)
                               .WaitAndRetryForever(_ => TimeSpan.FromMilliseconds(500))
                   .Execute(() => this.TryEnterLock());
}

不过要是能用纯波利来表达就好了……

Answer 1

说实话，我不明白 1 勾 是什么意思，在你的情况下？它是一纳秒还是更大？您的全局超时应大于本地超时。

但正如我所见，您没有指定本地人。 TryEnterLock 应该收到一个 TimeSpan 以便不会无限期地阻塞调用者。如果您查看内置的同步原语，其中大多数都提供了这样的功能：Monitor.TryEnter、SpinLock.TryEnter、WaitHandle.WaitOne 等。

所以，总结一下：

var timeoutPolicy = Policy.Timeout(TimeSpan.FromMilliseconds(1000));
var retryPolicy = Policy.HandleResult(false)
       .WaitAndRetryForever(_ => TimeSpan.FromMilliseconds(500));
var resilientStrategy = Policy.Wrap(timeoutPolicy, retryPolicy);    

var result = resilientStrategy.Execute(() => this.TryEnterLock(TimeSpan.FromMilliseconds(100))); 

超时和延迟值应根据您的业务需求进行调整。我强烈建议您在全局超时 (onTimeout / onTimeoutAsync) 触发和重试时 (onRetry / onRetryAsync) 进行记录，以便能够微调/校准这些值。

---

编辑：基于这篇文章的 cmets

事实证明，timeoutFromApiCaller 无法控制，因此它可以任意小。 （在给定的示例中，它只有几纳秒，目的是强调问题。）因此，为了获得至少一个呼叫保证，我们必须使用Fallback policy。

我们应该将其称为最后一个操作来满足要求，而不是在策略之外预先手动调用TryEnterLock。因为策略使用升级，所以每当 inner 失败时，它会将问题委托给下一个 outer 策略。

因此，如果提供的超时时间太短以至于操作在该时间段之前无法完成，那么它将抛出TimeoutRejectedException。使用 Fallback，我们可以处理这个问题，并且可以再次执行该操作，但现在没有任何超时限制。这将为我们提供所需的至少一项保证。

var atLeastOnce = Policy.Handle<TimeoutRejectedException>
    .Fallback((ct) => this.TryEnterLock());
var globalTimeout = Policy.Timeout(TimeSpan.FromMilliseconds(1000));
var foreverRetry = Policy.HandleResult(false)
       .WaitAndRetryForever(_ => TimeSpan.FromMilliseconds(500));

var resilientStrategy = Policy.Wrap(atLeastOnce, globalTimeout, foreverRetry);    
var result = resilientStrategy.Execute(() => this.TryEnterLock());