在这种情况下,预期的是,如果用户通过按回车键取消任务,则另一个任务会被挂钩ContinueWith
会运行,但事实并非如此,根据AggregateException
尽管在中进行了显式处理,但仍会抛出ContinueWith
这显然没有被执行。
请对以下内容进行澄清吗?
class Program
{
static void Main(string[] args)
{
CancellationTokenSource tokensource = new CancellationTokenSource();
CancellationToken token = tokensource.Token;
Task task = Task.Run(() =>
{
while (!token.IsCancellationRequested)
{
Console.Write("*");
Thread.Sleep(1000);
}
}, token).ContinueWith((t) =>
{
t.Exception.Handle((e) => true);
Console.WriteLine("You have canceled the task");
}, TaskContinuationOptions.OnlyOnCanceled);
Console.WriteLine("Press any key to cancel");
Console.ReadLine();
tokensource.Cancel();
task.Wait();
}
}
让我们从几个事实开始:
- 当你通过一个
CancellationToken
作为参数Task.Run
仅当取消时才有效before任务开始运行。如果任务已经在运行,它将not被取消。
- 取消任务after它已经开始运行,你需要使用
CancellationToken.ThrowIfCancellationRequested
, not CancellationToken.IsCancellationRequested
.
- 如果任务被取消,它的
Exception
属性没有任何例外,并且是null
.
- 如果延续任务由于某种原因没有运行,则意味着它已被取消。
- 任务包含其自身+所有子任务的异常(因此,
AggregateException
).
这就是您的代码中发生的情况:
任务开始运行,因为令牌未取消。它将运行直到令牌被取消。之后它将结束延续will notrun 因为它仅在前面的任务被取消时运行,而事实并非如此。当你Wait
它将抛出的任务AggregateException
with a TaskCanceledException
因为延续被取消(如果您删除该延续,则异常将消失)。
解决方案:
您需要修复该任务,使其实际上被取消,并删除(或空检查)异常处理,因为没有异常:
var task = Task.Run(new Action(() =>
{
while (true)
{
token.ThrowIfCancellationRequested();
Console.Write("*");
Thread.Sleep(1000);
}
}), token).ContinueWith(
t => Console.WriteLine("You have canceled the task"),
TaskContinuationOptions.OnlyOnCanceled);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)