执行两个查询作为任务[重复]

Question

我需要帮助来了解 Task 在 c# 中的工作原理。我想为clauses 中的每个子句调用一次ExecuteClause。我发现我应该创建一个任务列表，然后

await Task.WhenAll(taskList);

最后我可以得到每个任务的结果。这是我目前所拥有的：

public async Task Execute(string[] clauses)
{
    var taskList = new List<Task<in>>();

    // Here I want to call ExecuteClause for each string in clauses
    // and wait for the result.
}

private async Task<int> ExecuteClause(string clause)
{
    var connectionString = ConfigurationManager.ConnectionStrings["default"].ConnectionString;
    var connection = new SqlConnection(connectionString);
    await connection.OpenAsync();

    var r = await new SqlCommand(clause, connection).ExecuteReaderAsync();

    while (await r.ReadAsync())
    {
        ...
    }

    r.Close();

    connection.Close();

    // Just an example returning an int
    return 1;
}

Answer 1

我认为答案比你想象的要简单。

您将遍历clauses 数组，并在每次迭代中将一个新任务添加到taskList。之后，您将使用 WhenAll 将所有单独的任务聚合成一个在所有组成任务完成后返回的单个任务：

public async Task Execute(string[] clauses)
{
    var taskList = clauses.Select(ExecuteClause);
    return Task.WhenAll(taskList);
}

您需要修复您的 ExecuteClause 方法以确保正确处理，因为它当前的编写方式可能无法在所有情况下处理连接：

private async Task<int> ExecuteClause(string clause)
{
    var connectionString = ConfigurationManager
                 .ConnectionStrings["default"].ConnectionString;
    using (var connection = new SqlConnection(connectionString)) {

        await connection.OpenAsync();

        var r = await new SqlCommand(clause, connection).ExecuteReaderAsync();

        while (await r.ReadAsync())
        {
            ...
        }

        r.Close();

        connection.Close();
    }
    // Just an example returning an int
    return 1;
}