在循环中并行执行异步 Task<T> 方法[关闭]

Question

我有一个带有async Task<Result> 方法的程序，而不是我需要从一个循环中并行运行。 这是我尝试过的两种方法，第一种（ResolveWidgetsTaskFactoryAsync）按预期工作，但另一种（ResolveWidgetsNotParallelAsync）同步运行，即使每个方法都作为任务返回。 在保持异步 Task<string> 返回类型为 ComputeAsync 的同时，我怎样才能更好地编写并行版本？

void Main()
{
    var results = ResolveWidgetsTaskFactoryAsync().Result;
    results.Dump();

    results = ResolveWidgetsNotParallelAsync().Result;
    results.Dump();
}

/// <summary>
/// Runs synchronously instead of in parallel
/// /summary>
private async Task<IEnumerable<string>> ResolveWidgetsNotParallelAsync()
{
    var values = new[] { "a", "b", "c" };
    var widgets = new List<Task<string>>();

    foreach (var value in values)
    {
        Console.WriteLine("Iteration value : " + value);

        var widgetTask = ComputeAsync(value);
        widgets.Add(widgetTask);
    }

    return await Task.WhenAll(widgets);
}

/// <summary>
/// Runs as expected, but I'm not sure it's well written
/// /summary>
private async Task<IEnumerable<string>> ResolveWidgetsTaskFactoryAsync()
{
    var values = new[] { "a", "b", "c" };
    var widgets = new List<Task<string>>();

    foreach (var value in values)
    {
        Console.WriteLine("Iteration value : " + value);

        widgets.Add(Task<string>.Factory.StartNew(() => ComputeAsync(value).Result));
    }

    return await Task.WhenAll(widgets);
}

public async Task<string> ComputeAsync(string value)
{
    try
    {
        Console.WriteLine("Processing value : " + value);

        Random rnd = new Random();
        var wait = rnd.Next(1000, 5000);
        Console.WriteLine("Wait : " + wait);
        Thread.Sleep(wait);

        return await Task.FromResult(value + " done");
    }
    catch (Exception e)
    {
        return null;
    }
}

Answer 1

要以更好的方式编写并行版本，您应该首先意识到您的代码本质上是同步的。它没有什么异步的。将同步代码包装在异步 API 中只会带来复杂性和混乱。所以我的建议是从你的代码中删除所有Task、async 和await 关键字，并使用Parallel 类或PLINQ 库来并行化它。下面是一个 PLINQ 示例：

public string Compute(string value)
{
    //...
}

private string[] ResolveWidgetsParallel()
{
    var values = new[] { "a", "b", "c" };
    return values
        .AsParallel()
        .AsOrdered()
        .Select(value => Compute(value))
        .ToArray();
}