使用 ContinueWith 时如何捕获 OperationCanceledException
How to catch an OperationCanceledException when using ContinueWith
我有一些代码要从 .NET 4.5 的可爱 async
和 await
关键字降级到 .NET 4.0。我正在使用 ContinueWith
创建类似于 await
工作方式的延续。
基本上,我的旧代码是:
var tokenSource = newCancellationTokenSource();
var myTask = Task.Run(() =>
{
return MyStaticClass.DoStuff(tokenSource.Token);
}, tokenSource.Token);
try
{
var result = await myTask;
DoStuffWith(result);
}
catch (OperationCanceledException)
{
// Cancel gracefully.
}
(正如人们所料,MyStaticClass.DoStuff(token)
定期调用 token.ThrowIfCancellationRequested()
。)
我的新代码如下所示:
var tokenSource = new CancellationTokenSource();
try
{
Task.Factory.StartNew(() =>
{
return MyStaticClass.DoStuff(tokenSource.Token);
}, tokenSource.Token)
.ContinueWith(task =>
{
var param = new object[1];
param[0] = task.Result;
// I need to use Invoke here because "DoStuffWith()" does UI stuff.
Invoke(new MyDelegate(DoStuffWith, param));
});
}
catch (OperationCanceledException)
{
// Cancel gracefully.
}
然而,OperationCanceledException
从未被捕获。这是怎么回事?我的 try/catch 块放在哪里?
取消的处理方式与其他异常不同。基本上,您可以使用这种模式:
Task.Factory.StartNew(() =>
{
// The task
}, tokenSource.Token)
.ContinueWith(task =>
{
// The normal stuff
}, TaskContinuationOptions.OnlyOnRanToCompletion)
.ContinueWith(task =>
{
// Handle cancellation
}, TaskContinuationOptions.OnlyOnCanceled)
.ContinueWith(task =>
{
// Handle other exceptions
}, TaskContinuationOptions.OnlyOnFaulted);
或备选方案:
Task.Factory.StartNew(() =>
{
// The task
}, tokenSource.Token)
.ContinueWith(task =>
{
switch (task.Status)
{
case TaskStatus.RanToCompletion:
// The normal stuff
break;
case TaskStatus.Canceled:
// Handle cancellation
break;
case TaskStatus.Faulted:
// Handle other exceptions
break;
}
});
在你的例子中,你没有捕捉到任何东西,因为:
Task.Factory.StartNew
returns 立即并且总是成功。
- 您的延续始终运行
- 访问
task.Result
抛出一个 AggregateException
因为任务被取消了
异常未被任何处理,因为它是从线程池线程中抛出的。哎呀。接下来会发生什么depends on the framework version:
- 在 .NET < 4.5 中,一旦失败的任务完成,进程将立即终止,因为您有未观察到的异常。
- 在 .NET >= 4.5 中,异常将被静默删除。
我有一些代码要从 .NET 4.5 的可爱 async
和 await
关键字降级到 .NET 4.0。我正在使用 ContinueWith
创建类似于 await
工作方式的延续。
基本上,我的旧代码是:
var tokenSource = newCancellationTokenSource();
var myTask = Task.Run(() =>
{
return MyStaticClass.DoStuff(tokenSource.Token);
}, tokenSource.Token);
try
{
var result = await myTask;
DoStuffWith(result);
}
catch (OperationCanceledException)
{
// Cancel gracefully.
}
(正如人们所料,MyStaticClass.DoStuff(token)
定期调用 token.ThrowIfCancellationRequested()
。)
我的新代码如下所示:
var tokenSource = new CancellationTokenSource();
try
{
Task.Factory.StartNew(() =>
{
return MyStaticClass.DoStuff(tokenSource.Token);
}, tokenSource.Token)
.ContinueWith(task =>
{
var param = new object[1];
param[0] = task.Result;
// I need to use Invoke here because "DoStuffWith()" does UI stuff.
Invoke(new MyDelegate(DoStuffWith, param));
});
}
catch (OperationCanceledException)
{
// Cancel gracefully.
}
然而,OperationCanceledException
从未被捕获。这是怎么回事?我的 try/catch 块放在哪里?
取消的处理方式与其他异常不同。基本上,您可以使用这种模式:
Task.Factory.StartNew(() =>
{
// The task
}, tokenSource.Token)
.ContinueWith(task =>
{
// The normal stuff
}, TaskContinuationOptions.OnlyOnRanToCompletion)
.ContinueWith(task =>
{
// Handle cancellation
}, TaskContinuationOptions.OnlyOnCanceled)
.ContinueWith(task =>
{
// Handle other exceptions
}, TaskContinuationOptions.OnlyOnFaulted);
或备选方案:
Task.Factory.StartNew(() =>
{
// The task
}, tokenSource.Token)
.ContinueWith(task =>
{
switch (task.Status)
{
case TaskStatus.RanToCompletion:
// The normal stuff
break;
case TaskStatus.Canceled:
// Handle cancellation
break;
case TaskStatus.Faulted:
// Handle other exceptions
break;
}
});
在你的例子中,你没有捕捉到任何东西,因为:
Task.Factory.StartNew
returns 立即并且总是成功。- 您的延续始终运行
- 访问
task.Result
抛出一个AggregateException
因为任务被取消了 异常未被任何处理,因为它是从线程池线程中抛出的。哎呀。接下来会发生什么depends on the framework version:
- 在 .NET < 4.5 中,一旦失败的任务完成,进程将立即终止,因为您有未观察到的异常。
- 在 .NET >= 4.5 中,异常将被静默删除。