C#任务 - 链接的取消令牌无效

Question

如果有人可以帮助我,请 我正在尝试使用TPL链接取消令牌.问题是在取消主要CancellationTokenSource后,链接令牌的属性IsCancellationRequested的值仍为"false".

我开始做两件事,只是为了确定 - 但它应该是一样的.到第一个我通过CancellationToken,到第二个我通过CancellationTokenSource.行为是相同的:在while循环中 - 条件linkedToken.IsCancellationRequested在取消后保持"false".

这是我正在使用的代码:

public class Manager
{
    private Task tokenTask;
    private Task sourceTask;
    private CancellationTokenSource mainCancelationTokenSource;
    private CancellationToken mainToken;

    public Manager()
    {
        this.mainCancelationTokenSource = new CancellationTokenSource();
        this.mainToken = mainCancelationTokenSource.Token;
        this.mainToken.Register(MainCanceled);
    }

    public void Start()
    {
        Workers w = new Workers();
        tokenTask = Task.Run(() => w.DoWorkToken(mainToken), mainToken);
        sourceTask = Task.Run(() => w.DoWorkSource(mainCancelationTokenSource), mainCancelationTokenSource.Token);

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

    private void MainCanceled()
    {
        try
        {
            tokenTask.Wait();
        }
        catch (Exception e)
        {

        }

        try
        {
            sourceTask.Wait();
        }
        catch (Exception e)
        {

        }
    }
}

class Workers
{
    public void DoWorkToken(CancellationToken mainToken)
    {
        CancellationTokenSource linkedCts = CancellationTokenSource.CreateLinkedTokenSource(mainToken);
        CancellationToken linkedToken = linkedCts.Token;

        while (!linkedToken.IsCancellationRequested)
        {
            Random r = new Random();
            Task.Delay(200 * r.Next(1, 11)).Wait();
        }

        linkedToken.ThrowIfCancellationRequested();
    }

    public void DoWorkSource(CancellationTokenSource mainCts)
    {
        CancellationTokenSource linkedCts = CancellationTokenSource.CreateLinkedTokenSource(mainCts.Token);

        while (!linkedCts.Token.IsCancellationRequested)
        {
            Random r = new Random();
            Task.Delay(200 * r.Next(1, 11)).Wait();
        }

        linkedCts.Token.ThrowIfCancellationRequested();
    }
}

从控制台应用程序启动此代码主方法:

class Program
{
    static void Main(string[] args)
    {
            Manager manager = new Manager();
            manager.Start();
            //Console.ReadKey();

            Thread.Sleep(5000);
            manager.Cancel();
   }
}

谢谢您的帮助!

Answer 1

这个问题的根源是这一行:

this.mainToken.Register(MainCanceled);

您注册一个回调以在令牌被取消时执行.在内部,该回调被委托给父进程CancellationTokenSource,并被放入一些回调列表中,以便在请求源取消时执行.在那个处理程序中你做

tokenTask.Wait();
sourceTask.Wait();

因此,在相关任务完成之前,此回调将不会完成.在任务中,你这样做

while (!linkedToken.IsCancellationRequested) {
    // loop here
}

因此,在请求取消之前,任务将无法完成.

现在到了棘手的部分:当你创建链接令牌源时

CancellationTokenSource.CreateLinkedTokenSource(mainToken)

这将也把一个回调父(mainToken)令牌源的列表.执行此回调时 - 链接的令牌源也会被取消.此回调将在列表中的回调之后.

因此,您将陷入僵局,因为第一个回调(您的)等待任务完成,任务等待链接的令牌IsCancellationRequested等于true,并且链接的令牌源等待它自己的回调完成以设置此标志.

要解决此问题,只需删除回调,或以不阻止等待相关任务完成的方式写入回调,或将任务更改为不等待链接的令牌源IsCancellationRequested标志.