我想向X个不同的Web服务请求,他们将返回true或false.
这些任务应该并行执行,我想等待第一个完成一个真正的值.当我收到真正的价值时,我不希望等待其他任务完成.
在下面的示例中,t1不应该等待,因为t3首先完成并返回true：
- var t1 = Task.Run<bool>(() =>
- {
- Thread.Sleep(5000);
- Console.WriteLine("Task 1 Excecuted");
- return true;
- },cts.Token);
- var t2 = Task.Run<bool>(() =>
- {
- Console.WriteLine("Task 2 Executed");
- return false;
- },cts.Token);
- var t3 = Task.Run<bool>(() =>
- {
- Thread.Sleep(2000);
- Console.WriteLine("Task 3 Executed");
- return true;
- },cts.Token);
本质上我正在寻找Task.WhenAny与谓词,当然不存在.
解决方法
您可以简单地使用Task.WhenAny和谓词多次,直到“正确”任务出现
- async Task<T> WhenAny<T>(IEnumerable<Task<T>> tasks,Func<T,bool> predicate)
- {
- var taskList = tasks.ToList();
- Task<T> completedTask = null;
- do
- {
- completedTask = await Task.WhenAny(taskList);
- taskList.Remove(completedTask);
- } while (!predicate(await completedTask) && taskList.Any());
- return completedTask == null ? default(T) : await completedTask;
- }
