从头开始异步处理

Question

我有以下名为 Pluck 的课程：

internal static void Work()
{
    Task[] tasks = new Task[5];
    for (int i = 0; i < tasks.Length; i++)
    {
        tasks[i] = SumAsync();
    }
    Task.WhenAll(tasks);
}

private static async Task<int> SumAsync()
{
    return await Task.Run(() => { return OnePlusOne(); });
}

private static int OnePlusOne()
{  return 1+1;  }

还有我的主要方法：

static void Main(string[] args)
{
    Pluck.Work(); 
}

我遗漏了一些东西，因为我在 OnePlusOne 中切换了一个断点并且永远不会被命中。

Answer 1

Task.WhenAll(tasks) 是一个async 方法，因此返回一个Task。您需要await 该任务以确保仅在完成所有任务后继续。目前，您的应用程序可能会在这些任务有机会运行之前结束。

这导致使用 async 关键字标记 Work 并让它返回 Task 本身：

internal static async Task WorkAsync()
{
    Task[] tasks = new Task[5];
    for (int i = 0; i < tasks.Length; i++)
    {
        tasks[i] = SumAsync();
    }
    await Task.WhenAll(tasks);
}

由于不能在Main中使用await，所以需要与Wait同步等待：

static void Main(string[] args)
{
    Pluck.WorkAsync().Wait(); 
}

如果单个await 是您在方法中执行的最后一件事（如在您的SumAsync 和我的WorkAsync 中），您可以删除它和async 关键字并简单地返回任务。这略微提高了性能。更多相关信息here。

---

注意：您应该只在非常特殊的情况下（例如在Main 内部）阻止带有Wait 的任务，因为它可能导致死锁。更好的解决方案是使用AsyncContext。