这个 foreach 最干净的异步版本？

Question

我在 AWS Lambda 中有一个方法，它接收完整的项目列表。它处理这些项目，然后将它们插入到 Dynamo DB 表中。处理或插入数据库的顺序无关紧要。

我正在寻找最线程安全且易于理解的方式来加快运行速度；通过使用async await 或其他（可能是并行的？）操作。

我在想Parallel.ForEach()，但这似乎有点沉重。有没有更简单、更明显的方法？

private async Task<int> LoadAutocomplete(IList<Item> resp)
{
    var client = new AmazonDynamoDBClient();

    foreach (var item in resp)
    {
        var request = new PutItemRequest
        {
            TableName = EnvironmentHelper.DynamoTableName,
            Item = new Dictionary<string, AttributeValue>()
            {
                { "LANGUAGE", new AttributeValue { S = item.LANGUAGE }},
                { "COUNTRY", new AttributeValue { S = item.COUNTRY }}
            }
        };
        await client.PutItemAsync(request);

        System.Threading.Thread.Sleep(100);
    }
}

选项 1

private async Task<int> LoadAutocomplete(IList<Item> resp)
{
    var client = new AmazonDynamoDBClient();

    Parallel.ForEach(resp, async item =>
    {
        var request = new PutItemRequest
        {
            TableName = EnvironmentHelper.DynamoTableName,
            Item = new Dictionary<string, AttributeValue>()
            {
                { "LANGUAGE", new AttributeValue { S = item.LANGUAGE }},
                { "COUNTRY", new AttributeValue { S = item.COUNTRY }}
            }
        };
        await client.PutItemAsync(request);
    }
}

选项 2 导致编译器抱怨 LoadAutoComplete 方法“缺少等待操作符并且将同步运行”。

选项 2 正如@jamesfaix 建议的那样

private async Task<int> LoadAutocomplete(IList<Item> resp)
{
    var client = new AmazonDynamoDBClient();
    
    var tasks = items.Select(x => DoSomethingAsync(client, x)).ToList();
    
    await Task.WhenAll(tasks);
}

private DoSomething(AmazonDynamoDBClient client, Item item)
{
    var request = new PutItemRequest
    {
        TableName = EnvironmentHelper.DynamoTableName,
        Item = new Dictionary<string, AttributeValue>()
        {
            { "LANGUAGE", new AttributeValue { S = item.LANGUAGE }},
            { "COUNTRY", new AttributeValue { S = item.COUNTRY }}
        }
    };
    
    await client.PutItemAsync(request);
}

选项 + @martin 建议

"Use Parallel.For in batches in dotnet core" 帖子确实回答了我的问题，但我选择了@jamesfaix 发布的the answer，因为它大大改进了我的代码。

Answer 1

以下是我将首先进行的一些基本更改。您可能还可以从那里进行其他改进。

1. 避免在异步代码中使用Thread.Sleep。 Task.Delay 是异步等效项。
2. 在等待之前创建许多任务。如果可以，运行时将尝试同时运行一些。

private async Task<int> LoadAutocomplete2(IList<Item> resp)
{
    var client = new AmazonDynamoDBClient();

    var tasks = resp.Select(async item =>
    {
        var request = new PutItemRequest
        {
            TableName = EnvironmentHelper.DynamoTableName,
            Item = new Dictionary<string, AttributeValue>()
            {
                { "LANGUAGE", new AttributeValue { S = item.LANGUAGE }},
                { "COUNTRY", new AttributeValue { S = item.COUNTRY }}
            }
        };

        var result = await client.PutItemAsync(request);
        await Task.Delay(100);
        return result;
    })
    .ToList(); // Make sure to materialize the IEnumerable!

    await Task.WhenAll(tasks);
}