c# - CancellationTokenSource.CancelAfter 不工作

Question

我正在尝试在这篇文章的基础上实现一些重试逻辑（但有任务） 编写重试逻辑的最干净的方法？

重试逻辑的想法是实现第二个任务，在给定时间后触发取消

void Main()
{
    RetryAction(() => Sleep(), 500);
}

public static void RetryAction(Action action, int timeout)
{
    var cancelSource = new CancellationTokenSource();                
    cancelSource.CancelAfter(timeout);

    Task.Run(() => action(), cancelSource.Token);    
}

public static void Sleep() 
{
    System.Threading.Thread.Sleep(5000);
    "done".Dump();
}

上面是一个 linqPad 片段（因此是“done”.Dump()）

知道为什么 CancelAfter 从不工作吗？

Answer 1

您的 Sleep 方法忽略了 CancellationToken。

尝试类似的东西

public static CancellationTokenSource cancelSource ;

void Main()
{
    RetryAction(() => Sleep(), 500);
}

public static void RetryAction(Action action, int timeout)
{
     cancelSource = new CancellationTokenSource();                
     cancelSource.CancelAfter(timeout);

     Task.Run(() => action(), cancelSource.Token);    
}

public static void Sleep() 
{
    for(int i = 0 ; i< 50; i++)
    {
        "Waiting".Dump();
        System.Threading.Thread.Sleep(100);

        if (cancelSource.IsCancellationRequested)
        {
            "Cancelled".Dump();
            return;
        }
    }
    "done".Dump();
}