如何正确重置 CancellationToken？

Posted 2023-03-31

【中文标题】如何正确重置 CancellationToken？

【英文标题】：How to reset a CancellationToken properly?

【发布时间】：2012-03-09 02:33:28

【问题描述】：

今天早上我一直在玩Async CTP，并有一个简单的程序，其中包含button 和label。单击button，它开始更新label，停止button，它停止写入label。但是，我不确定如何重置 CancellationTokenSource 以便我可以重新启动该过程。

我的代码：

public partial class MainWindow : Window

    CancellationTokenSource cts = new CancellationTokenSource();
    public MainWindow()
    
        InitializeComponent();
        button.Content = "Start";
    

    async Task DoWork(CancellationToken cancelToken)
    
        int i = 0;
        while (!cancelToken.IsCancellationRequested)
        
            label.Content = i++.ToString();
            await TaskEx.Delay(50, cancelToken);
        
    

    private void Button_Click(object sender, RoutedEventArgs e)
    
        if (button.Content == "Start")
        
            button.Content = "Stop";
            DoWork(cts.Token);
        
        else
        
            button.Content = "Start";
            cts.Cancel();
        
    

【参考方案1】：

您需要重新创建 CancellationTokenSource - 设置后无法“重置”它。

这可能很简单：

private void Button_Click(object sender, RoutedEventArgs e)

    if (button.Content == "Start")
    
        button.Content = "Stop";
        cts.Dispose(); // Clean up old token source....
        cts = new CancellationTokenSource(); // "Reset" the cancellation token source...
        DoWork(cts.Token);
    
    else
    
        button.Content = "Start";
        cts.Cancel();
    

【讨论】：

你应该在什么时候在应用程序关闭时处理它？因为你必须在线程完成之前等待，否则你会得到 ObjectDisposed 异常。

@user2587718 这真的取决于什么类型的对象等。我建议您对此提出自己的问题。

真的应该在处理之前做一个空检查，但这很好，因为这正是我正在做的。

想了解更多关于 CancellationTokens 的知识，为什么不在Cancel 通话后立即处理 cts？是否应该只在下次更新时才丢弃？

【参考方案2】：

我遇到了同样的问题，我发现解决它的最佳方法是在调用该方法之前重新创建取消令牌源。

这是我点击开始按钮时所做的：

cancellationTokenSource = new CancellationTokenSource();
cancellationToken = cancellationTokenSource.Token;
Task.Factory.StartNew(StartUpload, cancellationToken);

我将同一个按钮的标题更改为取消，当点击取消时，我调用

cancellationTokenSource.Cancel();

这里是完整的代码：

if (button3.Text != "&Start Upload")

    cancellationTokenSource.Cancel();

else

    try
    
        cancellationTokenSource = new CancellationTokenSource();
        cancellationToken = cancellationTokenSource.Token;
        Task.Factory.StartNew(StartUpload, cancellationToken);
    
    catch (AggregateException ex)
    
        var builder = new StringBuilder();
        foreach (var v in ex.InnerExceptions)
            builder.Append("\r\n" + v.InnerException);
        MessageBox.Show("There was an exception:\r\n" + builder.ToString());
    
    catch (Exception ex)
    
        MessageBox.Show(ex.Message);
    

【参考方案3】：

现在，在 .NET 6 中，您可以使用 TryReset() 方法，Attempts to reset the CancellationTokenSource to be used for an unrelated operation. 请参阅 this 问题和 CancellationTokenSource.cs 了解更多详细信息。