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

Question

我想向X提出不同的Web服务请求,每个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一个谓词,当然不存在.

Answer 1

你可以简单地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;
}

Answer 2

一种选择是使用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<bool>(async () =>
{
    await Task.Delay(TimeSpan.FromSeconds(1), cts.Token);
    Console.WriteLine("Task 1 Excecuted");
    return false;
}, cts.Token);