动态地将任务分配给Task数组以供Task.Factory.ContinueWhenAll处理

Question

我一直在使用位于 这里，学习了很多很棒的东西。

具体来说，我正在尝试构建一个简单的程序，该程序提取 rss 提要列表，然后解析出特定信息。

在解决方案AsyncDownload_CSharp中，它提供了许多如何异步下载的示例。我对下面的代码有了相当不错的理解：

// Concurrent async requests
Task.Factory.ContinueWhenAll(new []
{
    Download("http://blogs.msdn.com/pfxteam"),
    Download("http://blogs.msdn.com/nativeconcurrency"),
    Download("http://exampleexampleexample.com"), // will fail
    Download("http://msdn.com/concurrency"),
    Download("http://bing.com")
}, ConcurrentTasksCompleted).Wait();

上面的代码有任务硬代码列表，我一直在试图弄清楚如何在分配值的地方动态生成任务列表运行时通过 foreach 循环或其他重复循环获取 url。

我想出的动态构建任务列表并将其传递给 Task.Factory.ContinueWhenAll 的代码如下所示：

private void btnFeeds_Click(object sender, EventArgs e)
{
    string[] urls = new[] { "http://blogs.msdn.com/pfxteam",
        "http://msdn.com/concurrency", "http://bing.com" };
    List<Task<string>> tasks = new List<Task<string>>();

    foreach (string url in urls)
    {
        tasks.Add(Download(url));
    }
    
    Task.Factory.ContinueWhenAll(tasks, ConcurrentTasksCompleted).Wait();

}

不幸的是，当我单步执行调试器时，我不仅看到任务列表正在构建，但随着它们被添加到任务列表中，但我也看到它们在传递给 Task.Factory.ContinueWhenAll 之前被执行。

我想我需要使用 lambda 表达式，而不是 foreach 循环，将其中的每一个传递给 Task.Factory.ContinueWhenAll。不幸的是，我很难弄清楚如何使用 lambda 表达式应用任务的 url。

我不确定我想做的事情是否可行，因此任何建议、指示或帮助将不胜感激。

Answer 1

因为您正在使用方法 DownLoad(url) 来创建任务对象。在DownLoad(url)方法中，任务实际上已经开始了，你可以检查ParallelExtensionsExtras/Extensions/EAP/WebClientExtensions.cs中的代码

 /// <summary>Downloads the resource with the specified URI as a byte array, asynchronously.</summary> 
    /// <param name="webClient">The WebClient.</param> 
    /// <param name="address">The URI from which to download data.</param> 
    /// <returns>A Task that contains the downloaded data.</returns> 
    public static Task<byte[]> DownloadDataTask(this WebClient webClient, string address) 
    { 
        return DownloadDataTask(webClient, new Uri(address)); 
    } 

    /// <summary>Downloads the resource with the specified URI as a byte array, asynchronously.</summary> 
    /// <param name="webClient">The WebClient.</param> 
    /// <param name="address">The URI from which to download data.</param> 
    /// <returns>A Task that contains the downloaded data.</returns> 
    public static Task<byte[]> DownloadDataTask(this WebClient webClient, Uri address) 
    { 
        // Create the task to be returned 
        var tcs = new TaskCompletionSource<byte[]>(address); 

        // Setup the callback event handler 
        DownloadDataCompletedEventHandler handler = null; 
        handler = (sender, e) => EAPCommon.HandleCompletion(tcs, e, () => e.Result, () => webClient.DownloadDataCompleted -= handler); 
        webClient.DownloadDataCompleted += handler; 

        // Start the async work 
        try 
        { 
            webClient.DownloadDataAsync(address, tcs); 
        } 
        catch(Exception exc) 
        { 
            // If something goes wrong kicking off the async work, 
            // unregister the callback and cancel the created task 
            webClient.DownloadDataCompleted -= handler; 
            tcs.TrySetException(exc); 
        } 

        // Return the task that represents the async operation 
        return tcs.Task; 
    }