在 for 循环中启动任务，然后对所有任务执行 waitall

Question

我看到了几篇关于此的帖子...但大多数人是手动创建任务而不是从 API 接收它。

我有这个代码

        Task[] tasks = new Task[companyCount];
        // start all threads
        for(int i = 0; i < companyCount; i++) {
            string input = GetNextCompanyRecord(i);
            string token = GetUserToken();
            HttpClient client = GetHttpClient();
            StringContent content = CreateStringContent(input);
            var x = client.PostAsync(companyUrlString, content).ConfigureAwait(continueOnCapturedContext: false);
            tasks[i] = x;
        }
        Task.WaitAll(tasks);

目标是我在 for 循环中为每条记录启动任务，然后在所有任务启动时...执行单个 waitall。

问题是我无法将 x 变量分配给任务数组。

PostAsync 方法没有向我返回任务。相反，它返回 ConfiguredTaskAwaitable。但我希望我能得到 Task 并且能够将它添加到我的数组中，然后等待。

Answer 1

就这样吧：

Task<HttpResponseMessage>[] tasks = new Task<HttpResponseMessage>[companyCount];
for(int i = 0; i < companyCount; i++)
{
    string input = GetNextCompanyRecord(i);
    string token = GetUserToken();
    HttpClient client = GetHttpClient();
    StringContent content = CreateStringContent(input);
    var x = client.PostAsync(companyUrlString, content);
    tasks[i] = x;
}
Task.WaitAll(tasks);

但是，也许更清洁的方法是这样做：

var tasks =
    from i in Enumerable.Range(0, companyCount)
    let input = GetNextCompanyRecord(i)
    let token = GetUserToken()
    let client = GetHttpClient()
    let content = CreateStringContent(input)
    select client.PostAsync(companyUrlString, content);

Task.WaitAll(tasks.ToArray());

甚至更好：

using (var client = GetHttpClient())
{
    var tasks =
        from i in Enumerable.Range(0, companyCount)
        let input = GetNextCompanyRecord(i)
        let token = GetUserToken()
        let content = CreateStringContent(input)
        select client.PostAsync(companyUrlString, content);

    Task.WaitAll(tasks.ToArray());
}

Answer 2

PostAsync 是返回一个Task（准确地说是一个Task<HttpResponseMessage>），但是你在它上面调用ConfigureAwait，它返回一个ConfiguredTaskAwaitable。

尝试先获取对任务的引用，然后调用ConfigureAwait。

var task = client.PostAsync(companyUrlString, content);
ConfiguredTaskAwaitable awaitable = task.ConfigureAwait(continueOnCapturedContext: false);
tasks[i] = task;

另外，请考虑：

• 删除对 ConfigureAwait 的调用，因为您似乎不需要它。
• 如果您想在任务完成后检索任务结果，请将您的数组从 Task[] 更改为 Task<HttpResponseMessage>[]。