在异步编程中,经常需要使用CancellationToken来取消任务的执行。
但是通常情况下,一个耗时任务还需要有超时机制。那个如何让一个任务既可以超市自动取消也可以手动取消?
//创建两个cts(一个手动取消,一个超时取消) CancellationTokenSource cancellCts= new CancellationTokenSource(); CancellationTokenSource timeOutCts = new CancellationTokenSource(1000); //将两个cts组合 CancellationTokenSource compositeCts = CancellationTokenSource.CreateLinkedTokenSource(cancellCts.Token, timeOutCts.Token); try { //执行异步耗时任务 await DoLongTimeTask(compositeCts.Token) } catch (OperationCanceledException) { if (cancellCts.Token.IsCancellationRequested) { //手动取消 throw new OperationCanceledException(); } else if (timeOutCts.Token.IsCancellationRequested) { //超时取消 throw new TimeoutException(); } } finally { cancellCts.Dispose(); timeOutCts.Dispose(); compositeCts.Dispose(); }
上一篇:【PyTorch】多对象分割项目
下一篇:k8s核心知识总结