TPL等待任务以特定的返回值完成
我想向X提出不同的Web服务请求,每个Web服务都返回true
或false
。
这些任务应该并行执行,我想等待第一个以真值完成的任务。 当我收到真正的价值时,我不想等待其他任务完成。
在下面的示例中,不应等待 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
现在将为true
或false
并且任何剩余的任务都会被给予取消的信号。
如果要使用示例任务对此进行测试,则必须稍微修改它们以使用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);