我有两个共享相同取消令牌的并行任务,客户端要求两个结果列表,例如:
class ResponseDTO
{
public IEnumerable<Entity1> Entity1List { get; set; }
public IEnumerable<Entity2> Entity2List { get; set; }
}
这两个请求同时计算且相互依赖,因此如果其中一个列表没有结果,则无需等待另一个结果。
var cts = new CancellationTokenSource();
var token = cts.Token;
Task task1 = new Task(() =>
{
//fetch Entity1 results into entity1List
if (!entity1List.Any())
{
cts.Cancel();
}
else
{
responseDTO.Entity1List = entity1List;
}
}, token);
Task task2 = new Task(() =>
{
//fetch Entity2 results into entity2List
if (!entity2List.Any())
{
cts.Cancel();
}
else
{
responseDTO.Entity2List = entity2List;
}
}, token);
task1.Start();
task2.Start();
try
{
Task.WaitAll(new[] { task1, task2 }, token);
}
catch (OperationCanceledException oce)
{
return responseDTO;
}
catch (AggregateException ae)
{
foreach (var ex in ae.InnerExceptions)
//Log the exception
return responseDTO;
}
return responseDTO;
如果任务返回空列表,则取消工作正常。
我的问题是:如果其中一个任务抛出一般异常,如何取消另一个任务?
通过@noobed 评论解决。
try
{
//fetch Entity1 results into entity1List
}
catch
{
cts.Cancel();
}
一般异常情况下会被catch,cts可以用cancel来调用。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)