0

我目前正在使用 Async CTP，需要将此代码转换为可以使用 Task.WhenAll() 的代码。

到目前为止，我所做的是使用 UserState 对象并将我的标识符 (AID) 放入其中，然后在完成的事件中使用它。

但是 wc.DownloadFileTaskAsync 方法没有 UserState 的重载。我能做些什么？

for (int i = 0; i < SortedRecommendations.Count; i++)
{
    string tempfilepath = filepath + SortedRecommendations[i].Aid + ".jpg";

    if (File.Exists(tempfilepath))
        continue;

    WebClient wc = new WebClient();
    wc.DownloadFileCompleted += (s, e) =>
        {
            var q = SortedRecommendations.Where(x => x.Aid == (int)e.UserState);
            if (q.Count() > 0)
                q.First().Image = tempfilepath;
        };
    wc.DownloadFileAsync(new Uri(SortedRecommendations[i].Image.Replace("t.jpg", ".jpg")), tempfilepath, SortedRecommendations[i].Aid);
}

这基本上是我想出的，但是我在 y.Aid == SortedRecommendations[i].Aid 得到了一个超出范围的异常，因为我现在显然是在下载开始时的其他东西。我看到的唯一其他可能性是使用类似 TaskEx.Run( () => { // 同步下载数据 }; 但我不喜欢这种方法。

for (int i = 0; i < SortedRecommendations.Count; i++)
{
    string tempfilepath = filepath + SortedRecommendations[i].Aid + ".jpg";

    if (File.Exists(tempfilepath))
        continue;

    WebClient wc = new WebClient();
    wc.DownloadFileCompleted += (s, e) =>
    {
        var q = SortedRecommendations.Where(x => x.Aid == SortedRecommendations[i].Aid);
        if (q.Count() > 0)
            q.First().Image = tempfilepath;

    };
    tasks.Add(wc.DownloadFileTaskAsync(new Uri(SortedRecommendations[i].Image.Replace("t.jpg", ".jpg")), tempfilepath));
}

await TaskEx.WhenAll(tasks);
//Everything finished
4

1 回答 1

0

首先，我认为你不应该将你的逻辑建立在 ids 上（除非你真的必须这样做）。您应该使用对SortedRecommendations集合中对象的引用。

现在，如果你想一次只下载一个文件，你可以简单地使用await：

for (int i = 0; i < SortedRecommendations.Count; i++)
{
    string tempfilepath = filepath + SortedRecommendations[i].Aid + ".jpg";

    if (File.Exists(tempfilepath))
        continue;

    WebClient wc = new WebClient();
    var recommendation = SortedRecommendations[i];
    await wc.DownloadFileTaskAsync(new Uri(recommendation.Image.Replace("t.jpg", ".jpg")), tempfilepath);
    recommendation.Image = tempfilepath;
}

但是，如果您想同时开始所有下载，就像您的DownloadFileAsync()代码一样，您可以使用ContinueWith()。而且您不需要用户状态，这就是闭包的用途：

for (int i = 0; i < SortedRecommendations.Count; i++)
{
    string tempfilepath = filepath + SortedRecommendations[i].Aid + ".jpg";

    if (File.Exists(tempfilepath))
        continue;

    WebClient wc = new WebClient();
    var recommendation = SortedRecommendations[i];
    var downloadTask = wc.DownloadFileTaskAsync(new Uri(recommendation.Image.Replace("t.jpg", ".jpg")), tempfilepath);
    var continuation = downloadTask.ContinueWith(t => recommendation.Image = tempfilepath);
    tasks.Add(continuation);
}

await Task.WhenAll(tasks);

最好的解决方案可能是一次下载有限数量的文件，而不是一个或全部。这样做更复杂，一种解决方案是使用带有setActionBlock的 TPL Dataflow 。MaxDegreeOfParallelism

于 2012-07-20T13:24:16.567 回答