TPL等待任务以特定的返回值完成

我想向X提出不同的Web服务请求,每个Web服务都返回truefalse

这些任务应该并行执行,我想等待第一个以真值完成的任务。 当我收到真正的价值时,我不想等待其他任务完成。

在下面的示例中,不应等待 t1因为t3首先完成并返回true

 var t1 = Task.Run(() => { Thread.Sleep(5000); Console.WriteLine("Task 1 Excecuted"); return true; }, cts.Token); var t2 = Task.Run(() => { Console.WriteLine("Task 2 Executed"); return false; }, cts.Token); var t3 = Task.Run(() => { Thread.Sleep(2000); Console.WriteLine("Task 3 Executed"); return true; }, cts.Token); 

基本上我正在寻找具有谓词的Task.WhenAny ,当然不存在。

您可以简单地多次使用Task.WhenAny和谓词,直到“正确”任务出现

 async Task WhenAny(IEnumerable> tasks, Func predicate) { var taskList = tasks.ToList(); Task completedTask = null; do { completedTask = await Task.WhenAny(taskList); taskList.Remove(completedTask); } while (!predicate(await completedTask) && taskList.Any()); return completedTask == null ? default(T) : await completedTask; } 

一种选择是使用Reactive Extensions 。 让我们假设你有一组任务。 这可能是您在问题中提到的任务:

 var tasks = new[] { t1, t2, t3 }; 

要并行执行任务并在第一个任务返回true时返回,请使用以下表达式:

 var result = await tasks .Select(t => t.ToObservable()) .Merge() .FirstOrDefaultAsync(success => success); 

任务被转换为可观察的序列,每个任务在任务完成时“触发”一次。 然后将这些序列合并为单个序列,然后将其“转换”回可以使用谓词等待的事物。 如果有必要,您可以使用更复杂的谓词而不是success => success

在此之后,如果您使用的是CancellationTokenSource则可以取消剩余的未完成任务:

 cts.Cancel(); 

变量result现在将为truefalse并且任何剩余的任务都会被给予取消的信号。

如果要使用示例任务对此进行测试,则必须稍微修改它们以使用Task.Delay而不是Thread.Sleep来启用任务取消:

 var t1 = Task.Run(async () => { await Task.Delay(TimeSpan.FromSeconds(1), cts.Token); Console.WriteLine("Task 1 Excecuted"); return false; }, cts.Token);