如何从控制台应用程序中的 Task.WaitAll() 获取返回值？

Question

我正在使用控制台应用程序作为概念验证和获取异步返回值的新需求。

我发现我需要在我的 main 方法中使用 Task.WaitAll() 以避免需要异步“main()”方法，这是非法的。

我现在一直在试图找出一个允许我使用泛型或只返回一个我可以转换的对象的重载，但是在 Main() 中。

Answer 1

您没有从Task.WaitAll 获得返回值。你只用它来等待多个任务完成，然后从任务本身获取返回值。

var task1 = GetAsync(1);
var task2 = GetAsync(2);
Task.WaitAll(task1, task2);
var result1 = task1.Result;
var result2 = task2.Result;

如果您只有一个 Task，只需使用 Result 属性。如果任务尚未完成，它将返回您的值并阻塞调用线程：

var task = GetAsync(3);
var result = task.Result;

---

在异步任务（“同步异步”）上同步等待（阻塞）通常不是一个好主意，但我想这对于 POC 来说很好。

Answer 2

为获得最佳实践，请使用新的异步处理方式。 而不是

• Task.WaitAll 使用 await Task.WhenAll
• Task.WaitAny 使用 await Task.WhenAny

上面的代码可以写成：

var task1 = GetAsync(1);
var task2 = GetAsync(2);
var results = await Task.WhenAll(task1, task2);
var result1 = results[0];
var result2 = results[1];

Answer 3

根据上下文和您的需要，您可以使用不同的方法，但我尝试了 i3arnon 和 alltej 的答案，在调试中我发现它们都有相同的问题...我在其中运行了两个代码示例我制作的控制台应用程序。我在代码中设置了一个断点，发现在使用Task.WaitAll 或Task.WhenAll 的执行行上。当我检查任务时，我发现它们已经运行了 - 任务属性 Status 是 = ran to completion。事实上，我能够完全删除Task.这行代码并仍然分配变量值，所以它没有用。

我发现真正让这种操作按要求运行并获得所需的返回值是一项非常困难的任务。这是我想出的：

Task[] taskArray = {
    Task.Factory.StartNew(() => ExecuteConcurrentTasks(1).Result),
    Task.Factory.StartNew(() => ExecuteConcurrentTasks(2).Result)
};
Task.WaitAll(taskArray);
var s = ((Task<string>)taskArray[0]).Result;

这是一个简单的示例，其中创建了一个任务数组，然后使用Task.WaitAll 同时执行两个任务，然后在最后一行中，我将展示如何访问第一个任务的返回值。

这是包含更多上下文和更多数据的代码：

private static async void MyAsyncMethod()
{
    Task[] taskArray = {
        Task.Factory.StartNew(() => ExecuteConcurrentTasks(1).Result),
        Task.Factory.StartNew(() => ExecuteConcurrentTasks(2).Result),
        Task.Factory.StartNew(() => ExecuteConcurrentTasks(3).Result),
        Task.Factory.StartNew(() => ExecuteConcurrentTasks(4).Result)
    };
    Task.WaitAll(taskArray);
    string s1 = ((Task<string>)taskArray[0]).Result;
    string s2 = ((Task<string>)taskArray[1]).Result;
    string s3 = ((Task<string>)taskArray[2]).Result;
    string s4 = ((Task<string>)taskArray[3]).Result;
}



private static async Task<string> ExecuteConcurrentTasks(int passedInt)
{
    string s = "Result: " + passedInt.ToString();

    if (passedInt == 4)
    {
        Console.WriteLine(s);
    }
    else if (passedInt == 3)
    {
        Console.WriteLine(s);
    }
    else if (passedInt == 2)
    {
        Console.WriteLine(s);
    }
    else if (passedInt == 1)
    {
        Console.WriteLine(s);
    }

    return s;
}

这是输出：

更新：

通过与其他一些开发人员的合作，我对这些方法有了更多的了解。我现在的理解是.WaitAll 将阻止程序其他部分的执行，如果您不只运行一个非常简单的程序，这是一个问题。另外.WhenAll 并不意味着任务不会在该行之前执行，并且都在该行开始异步执行，它只是意味着该块中的代码不会继续超过该点，除非所有指定的任务都已完成正在运行。