如何在 Windows Phone 上运行并行任务？

Question

我正在构建一个 WP8 应用程序，我需要执行大约 30 个网络请求。这些请求不相互依赖，因此可以并行化。

我的代码如下所示（简化/伪代码）：

foreach (Uri uri in uris)
{
    var rawData = await Task.Run(() => httpClient.GetStringAsync(uri).ConfigureAwait(false));

    var processedData = dataProcessor.Process(rawData);
    processedDataCollection.Add(processedData);
}

当我查看 Fiddler 时，请求都是按顺序执行的；执行和处理所有这些需要几秒钟。但是，我不希望代码等到 1 个请求完成后再移动到下一个请求，我想同时执行多个请求。

通常我会使用 Parallel.Invoke() 或 Parallel.ForEach() 或类似的东西来执行此操作，但显然 Parallel 库在 Windows Phone 8 中不可用。

那么最好的方法是什么？ Task.Factory.StartNew()? new Thread()?

Answer 1

无需在单独的线程上运行每个请求。你可以很容易地做到这一点：

var raw = await Task.WhenAll(uris.Select(uri => httpClient.GetStringAsync(uri)));
var processed = raw.Select(data => dataProcessor.Process(data)).ToArray();

此代码获取uris 的集合并为每个集合启动一个HTTP 下载(Select(...))。然后它异步等待它们全部完成 (WhenAll)。然后在第二行代码中处理所有数据。

但是，Windows Phone 运行时可能会限制您对同一服务器的最大请求数。

Answer 2

您正在将await 用于您创建的任务 - 这意味着您正在等待调用完成，然后再继续该方法。正如您所指出的，您的 foreach 没有并行化，因此您在这里所做的基本上是一些串行请求。

您可以使用Task.WaitAll 方法按照您（可能）想要的方式运行此程序。像这样的东西就足够了：

var tasks = new List<Task>();

foreach (Uri uri in uris)
{
    var thisTask = Task.Run(() => 
                       { 
                         httpClient.GetStringAsync(uri).ConfigureAwait(false);
                         var processedData = dataProcessor.Process(rawData);
                         processedDataCollection.Add(processedData);
                       });

    tasks.Add(thisTask);
}

Task.WaitAll(tasks);

请注意，这也会并行处理您的数据（也就是说，它也会并行调用 .Process），而您的原始代码没有这样做。

我还要补充一点，您可能不想一次运行 30 个请求，除非它们发往不同的服务器。在同一台服务器上同时向 Uris 发出 30 个请求不太可能缩短您的处理时间。 （幸运的是，TPL 可能会为您解决这个问题，因为它会在一定程度上限制并行性。）