TPL等待任务完成并返回一个特定的值

本文关键字：一个 任务 等待 返回 TPL | 更新日期: 2023-09-27 18:11:12

我想向X个不同的web服务发出请求，每个web服务将返回true或false。

这些任务应该并行执行，我想等待第一个以为真值完成的任务。当我收到一个true值时，我不希望等待其他任务完成。

在下面的例子中，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与谓词，当然不存在。

TPL等待任务完成并返回一个特定的值

您可以简单地使用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;
}

一个选择是使用响应式扩展。假设您有一组任务。它可以是你在问题中提到的任务:

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);
相关文章：