异步运行多个 Linq 查询

Question

我正在尝试弄清楚如何在我的应用程序的数据层中正确使用async/await 来并行执行多个数据库调用。

我正在使用 Entity Framework 和 Linq 进行数据调用。

可以从任何应用程序类型（MVC Web 应用程序、Web API 项目、Win From、Windows 服务等）调用数据层 - 因此方法的结果应该是单个对象。

    public static async void GetLedger(long id, DateTime StartDate, DateTime EndDate)
    {
        var task_1 = DoComplexDBCallAsync1();
        var task_2 = DoComplexDBCallAsync2();
        var task_3 = DoComplexDBCallAsync3();
        var task_4 = DoComplexDBCallAsync4();
        var task_5 = DoComplexDBCallAsync5();

        await Task.WhenAll(task_1, task_2, task_3, task_4, task_5);

        var result = ProcessAndMergeResultsFromAllDBCalls(task_1.Result, task_2.Result, task_3.Result, task_4.Result, task_5.Result);

        return result;
    }

    private static async Task<List<SomeComplexType>> DoComplexDBCallAsync1(long id)
    {
        using (var metadata = DataAccess.getDesktopMetadata())
        {
            var accounts = await (from row in metadata.db_GLAccount
                                  where row.busID == id
                                  select row).ToListAsync();

            return accounts;
        }
    }

如何更改上述内容以返回单个 object 而不是 Task<>？

我是否需要将其包装在另一个方法中，该方法通过Task run 或RunSynchronously() 调用GetLedger async 方法并返回结果？ 如果是这样，代码的外观如何？我需要注意什么？

在这种情况下最佳做法是什么？

Answer 1

你会使用 await 如下

    public static async Task<SomeObject> GetLedger(long id, DateTime StartDate, DateTime EndDate)
    {
        var task_1 = DoComplexDBCallAsync1();
        var task_2 = DoComplexDBCallAsync2();
        var task_3 = DoComplexDBCallAsync3();
        var task_4 = DoComplexDBCallAsync4();
        var task_5 = DoComplexDBCallAsync5();

        var result = ProcessAndMergeResultsFromAllDBCalls(await task_1, await task_2, await task_3, await task_4, await task_5);

        return result;
    }

'await' 关键字会在 DB 调用返回时自动获取 Task 的结果并将其应用于变量。 MSDN

然后你会打电话

var result = await GetLedger(id, StartDate, EndDate);

一切都完成后才会继续。