这是在这个 C# .NET 代码中使用异步等待的好选择吗？

Question

我有一个对象集合。在保存这些对象之前，我需要从数据库中获取一些参考数据。我需要为每个对象对数据库进行几次调用。这些方法可以按任何顺序发生/不相互依赖。

我可以使用async / await 使这些数据库操作同时发生 吗？

Parallel.ForEach(animals,
    animal => {
        animal.Owner = GetAnimalOwner(ownerId);
        animal.FavouriteFood = GetFavouriteFood(foodId);

        Database.Store(animal);
    });

这是一些伪代码，解释了我正在尝试做的事情。 这是async / await 的好人选吗？

Answer 1

如果你只想并行执行这两个操作，那么你不需要async-await。您可以使用旧的 TPL 方法，例如 Parallel.Invoke():

Parallel.ForEach(animals,
    animal => {
        Parallel.Invoke(
            () => animal.Owner = GetAnimalOwner(ownerId),
            () => animal.FavouriteFood = GetFavouriteFood(foodId));

        Database.Store(animal);
    });

请记住，不能保证这会真正提高您的性能，具体取决于您的数据库和您与它的连接。

一般来说，async-await 在两种情况下是有意义的：

1. 您想从 UI 线程中卸载一些长时间运行的代码。
2. 您希望使用更少的线程来提高性能或可扩展性。

在我看来，#1 不是你的情况。如果您是第 2 种情况，那么您应该将数据库方法重写为真正异步的方法（取决于您的数据库库，这可能是不可能的）。

如果你这样做，那么你可以做类似于 Scott Chamberlain 建议的事情（但不使用Parallel.ForEach()）：

var tasks = animals.Select(
    async animal => {
        var getOwnerTask = GetAnimalOwnerAsync(ownerId);
        var getFavouriteFoodTask = GetFavouriteFoodAsync(foodId);

        animal.Owner = await getOwnerTask;
        animal.FavouriteFood = await getFavouriteFoodTask;

        await Database.StoreAsync(animal);
    });

await Task.WhenAll(tasks);

这将以比Parallel.ForEach() 更大的并行度执行（因为受线程池的限制），但同样，这实际上可能不会提高性能。如果你想限制并行度，你可以添加SemaphoreSlim或者你可以使用TPL Dataflow来代替。