如何使用 Task.WaitAny() 确定哪些任务首先完成？

Question

在这段代码中，您总是得到相同的结果。我不知道为什么这些任务的ID是1,3,4。

如果您在int index = Task.WaitAny(tasks); 处设置断点并等待 2 秒，您将获得良好的结果。第一种情况的结果不同，ID分别等于1、2、3。

public class Example
{
    public static void Main()
    {
        var tasks = new Task[3];
        var rnd = new Random();
        for (int ctr = 0; ctr <= 2; ctr++)
            tasks[ctr] = Task.Run( () => Thread.Sleep(rnd.Next(500, 3000)));

        try 
        {
            int index = Task.WaitAny(tasks);
            Console.WriteLine("Task #{0} completed first.\n", tasks[index].Id);
            Console.WriteLine("Status of all tasks:");

            foreach (var t in tasks)
                Console.WriteLine("   Task #{0}: {1}", t.Id, t.Status);
        }
        catch (AggregateException) 
        {
            Console.WriteLine("An exception occurred.");
        }
    }
}

// The example displays output like the following:
//     Task #1 completed first.
//     
//     Status of all tasks:
//        Task #3: Running
//        Task #1: RanToCompletion
//        Task #4: Running

Answer 1

如果您查看Task.Id 的documentation，它会说：

任务 ID 是按需分配的，不一定代表 创建任务实例的顺序。请注意，虽然 冲突非常罕见，任务标识符不保证是 独一无二。

（强调我的）

因此，为此目的使用Task.Id（即检查首先完成的任务）绝不是可靠的。你应该做的是依赖数组中元素的索引。在这种情况下，您的代码将如下所示：

var tasks = new Task[3];
var rnd = new Random();
for (int ctr = 0; ctr <= 2; ctr++)
    tasks[ctr] = Task.Run(() => Thread.Sleep(rnd.Next(500, 3000)));

try
{
    int index = Task.WaitAny(tasks);
    Console.WriteLine("Task #{0} completed first.\n", (index + 1));
    Console.WriteLine("Status of all tasks:");

    for (int i = 0; i <= 2; i++)
        Console.WriteLine("   Task #{0}: {1}", (i + 1), tasks[i].Status);
}
catch (AggregateException)
{
    Console.WriteLine("An exception occurred.");
}

这样，当您多次运行程序时，您会得到不同的结果。你可以try it online。

更多关于Task.Id行为的信息，你可以阅读Stephen Cleary的文章：A Few Words on Task.Id (and TaskScheduler.Id)。

Answer 2

您应该考虑使用 Microsoft 的响应式框架（又名 Rx） - NuGet System.Reactive 并添加 using System.Reactive.Linq; - 然后您可以这样做：

var rnd = new Random();

IObservable<int> query =
    from n in Observable.Range(0, 3)
    from _ in Observable.Start(() => Thread.Sleep(rnd.Next(500, 3000)))
    select n;

IDisposable results =
    query.Subscribe(n => Console.WriteLine("Observable #{0} completed.", n));

我得到这样的输出：

Observable #0 已完成。 Observable #2 完成。 Observable #1 完成。

它通常比任务更强大，更具表现力。