CancellationToken 甚至为空

Question

在我的应用程序中，我运行了一个执行繁重操作的Task，我试图停止执行该Task。实际上我在课堂上声明了以下结构：

public class Foo
{
    private CancellationTokenSource tokenSource = new CancellationTokenSource();
    private CancellationToken token;

    public void Start()
    {
        var task = new Task(async () => {
           try
           {
               await new Bot().StartAsync(token);
           }
           catch(Exception ex)
           {
              Console.WriteLine(ex.ToString());
           }
        }, token));

        task.Start();
    }
}

如您所见，我声明了一个CancellationTokenSource，它允许我在用户单击按钮时停止任务执行：

StopTask_Click(object sender, EventArgs e) 
{
    tokenSource.Cancel();
}

现在，在 StartAsync 方法中，我有以下代码：

public async Task StartAsync(CancellationToken token)
{
    ApplicationToken = token;

    while(true)
    {
       if(ApplicationToken.IsCancellationRequested)
       {
           break;
       }
    }
}

ApplicationToken 将作为参数传递的令牌存储在StartAsync 方法的类中。

在按钮点击事件之后，请求应该被取消但没有任何反应。

然后我检查每次迭代是否有取消请求，但变量值甚至是false。

Answer 1

嗯，你好像忘了token = tokenSource.Token;

Edit1：您应该使用ThrowIfCancellationRequested()检查取消

编辑2：

using System;
using System.Threading;
using System.Threading.Tasks;

namespace CancellationTokenPOC
{
class Program
{
    public static async Task Main(string[] args)
    {
        Console.WriteLine("Hello World!");

        TokenPOC t = new TokenPOC();
        var longRunningTask = Task.Factory.StartNew(async () =>
        {
            for (int i = 0; i < 10; i++)
            {
                Console.WriteLine(i);
                t.token.ThrowIfCancellationRequested();

                await Task.Delay(10000);
            }

        });
        Console.ReadKey();
        t.source.Cancel();
        await Task.Delay(1000);
        Console.WriteLine("finishing");
    }
}

class TokenPOC
{
    public CancellationTokenSource source = new CancellationTokenSource();
    public CancellationToken token;
    public TokenPOC()
    {
        token = source.Token;
    }
}
}

此令牌被取消并按预期结束程序...

Answer 2

您传递的令牌与您尝试取消的令牌不同。你可以消除

private CancellationToken token;

改为传递给StartAsync()

tokenSource.Token

Answer 3

你可以试试下面的：

public class Foo
{
   var cancellationTokenSource = new CancellationTokenSource();
   var token = cancellationTokenSource.Token();

   public void Start() {
        var t = Task.Factory.StartNew(() =>
        {
            try
            {
               await new Bot().StartAsync(token);
            }
            catch(Exception ex)
            {
               Console.WriteLine(ex.ToString());
            }
        }, token).ContinueWith(task =>
          {
              if (!task.IsCompleted || task.IsFaulted)
              {
                 // Log
              }
          }, token);
    }

    StopTask_Click(object sender, EventArgs e) 
    {
          cancellationTokenSource.Cancel();
    }
}

Answer 4

首先，StartAsync 缺少 await 运算符，它将同步运行。

public async Task StartAsync(CancellationToken token)
{
    ApplicationToken = token;

    while (true)
    { 
        if (ApplicationToken.IsCancellationRequested) break;
        await Task.Delay(10, ApplicationToken); // => you may change it to concrete task
    }
}

其次，Foo 中的 CancellationToken 类是多余的，你甚至不需要初始化它。

new Bot().StartAsync(tokenSource.Token); 内部的 Start 方法不等待，因此在调用完成之前继续执行当前方法。

由于Start 方法无效，您应该使用GetAwaiter() 方法来执行Bot 类的任务。

public void Start()
{
    try
    {
        new Bot().StartAsync(tokenSource.Token).GetAwaiter();
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.ToString());
    }
}

最后，如果StopTask_Click 方法是Foo 类的成员，那么它应该可以正常工作。

---

这是一个如何使用CancellationTokenSource取消任务的示例

public partial class Form1 : Form
{
    private readonly Foo foo = new Foo();

    private void button1_Click(object sender, EventArgs e)
    {
        foo.Start();          
    }

    private void button2_Click(object sender, EventArgs e)
    {
        foo.Cancel();
    }
}

public class Foo
{
    private readonly CancellationTokenSource tokenSource = new CancellationTokenSource();

    public void Start()
    {
        try
        {
            new Bot().StartAsync(tokenSource.Token).GetAwaiter();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.ToString());
        }
    }

    public void Cancel()
    {
        tokenSource.Cancel();
    }
}

public class Bot
{
    private CancellationToken ApplicationToken;

    public async Task StartAsync(CancellationToken token)
    {
        ApplicationToken = token;

        while (true)
        { 
            if (ApplicationToken.IsCancellationRequested) break;
            await Task.Delay(10, ApplicationToken);
        }
    }
}