Csharp 将轮询与超时同步

您需要设置TimeoutStrategy.Pessimistic，因为Thread.Sleep不使用CancellationToken来中断其等待.

var retry = Policy
    .Handle<Exception>()
    .Retry(1);

var timeout = Policy
    .Timeout(1, Polly.Timeout.TimeoutStrategy.Pessimistic);

var wrap = Policy.Wrap(retry, timeout);

try
{
    wrap
        .Execute(() =>
        {
            "Enter executed logic".Dump();
            Thread.Sleep(5000);
            "Exit executed logic".Dump();
        });
}
catch(TimeoutRejectedException ex)
{
    ex.Message.Dump();
}

乐观意味着您的待修饰方法可以通过CancellationToken

var retry = Policy
    .Handle<Exception>()
    .Retry(1);

var timeout = Policy
    .Timeout(1, Polly.Timeout.TimeoutStrategy.Optimistic);

var wrap = Policy.Wrap(retry, timeout);

try
{
    wrap
        .Execute(token =>
        {
            "Enter executed logic".Dump();
            Task.Delay(5000, token).Wait(token);
            "Exit executed logic".Dump();
        }, CancellationToken.None);
}
catch(TimeoutRejectedException ex)
{
    ex.Message.Dump();
}

• 请注意，在本例中，我使用了不同的重载Execute.
• It is not mandatory to pass the token to both Delay and Wait
  • 只要传到Wait:Task.Delay(5000).Wait(token);就足够了.

DotNet小提琴链接:https://dotnetfiddle.net/ei6iPA