3

我一直在到处寻找 .net 4.5 中新的 Async 和 Await 功能的真实世界示例。我想出了以下代码来下载文件列表并限制并发下载的数量。我将不胜感激任何改进/优化此代码的最佳实践或方法。

我们使用以下语句调用以下代码。

await this.asyncDownloadManager.DownloadFiles(this.applicationShellViewModel.StartupAudioFiles, this.applicationShellViewModel.SecurityCookie, securityCookieDomain).ConfigureAwait(false);

然后，我们使用事件将下载的文件添加到 ViewModel 上的 observablecollection（.net 4.5 中的新线程安全版本）。

public class AsyncDownloadManager
    {
        public event EventHandler<DownloadedEventArgs> FileDownloaded;

        public async Task DownloadFiles(string[] fileIds, string securityCookieString, string securityCookieDomain)
          {
            List<Task> allTasks = new List<Task>();
            //Limits Concurrent Downloads 
            SemaphoreSlim throttler = new SemaphoreSlim(initialCount: Properties.Settings.Default.maxConcurrentDownloads);

            var urls = CreateUrls(fileIds);

            foreach (var url in urls)   
            {  
                await throttler.WaitAsync();
                allTasks.Add(Task.Run(async () => 
                {
                    try
                    {
                        HttpClientHandler httpClientHandler = new HttpClientHandler();
                        if (!string.IsNullOrEmpty(securityCookieString))
                        {
                            Cookie securityCookie;
                            securityCookie = new Cookie(FormsAuthentication.FormsCookieName, securityCookieString);
                            securityCookie.Domain = securityCookieDomain;
                            httpClientHandler.CookieContainer.Add(securityCookie);    
                        }                     

                        await DownloadFile(url, httpClientHandler).ConfigureAwait(false);
                    }
                    finally
                    {
                        throttler.Release();
                    }
                }));
            }
            await Task.WhenAll(allTasks).ConfigureAwait(false);
        }

        async Task DownloadFile(string url, HttpClientHandler clientHandler)
        {
            HttpClient client = new HttpClient(clientHandler);
            DownloadedFile downloadedFile = new DownloadedFile();

            try
            {
                HttpResponseMessage responseMessage = await client.GetAsync(url).ConfigureAwait(false);
                var byteArray = await responseMessage.Content.ReadAsByteArrayAsync().ConfigureAwait(false);

                if (responseMessage.Content.Headers.ContentDisposition != null)
                {
                    downloadedFile.FileName = Path.Combine(Properties.Settings.Default.workingDirectory, responseMessage.Content.Headers.ContentDisposition.FileName);
                }
                else
                {
                    return;
                }

                if (!Directory.Exists(Properties.Settings.Default.workingDirectory))   
                {
                    Directory.CreateDirectory(Properties.Settings.Default.workingDirectory);
                }
                using (FileStream filestream = new FileStream(downloadedFile.FileName, FileMode.Create, FileAccess.Write, FileShare.None, bufferSize: 4096, useAsync: true))
                {
                    await filestream.WriteAsync(byteArray, 0, byteArray.Length);
                }
            }
            catch(Exception ex)
            {    
                return; 
            }
            OnFileDownloaded(downloadedFile);
        }

        private void OnFileDownloaded(DownloadedFile downloadedFile)
        {    
            if (this.FileDownloaded != null)
            {
                this.FileDownloaded(this, new DownloadedEventArgs(downloadedFile));
            }
        }    

    public class DownloadedEventArgs : EventArgs
    {
        public DownloadedEventArgs(DownloadedFile downloadedFile)
        {   
            DownloadedFile = downloadedFile;
        }

        public DownloadedFile DownloadedFile { get; set; }
    }

根据 Svick 的建议 - 以下是直接问题：

  1. 在其他 Async / Await 方法中嵌入 Async / Await 有什么影响？（在 Async / Await 方法中将文件流写入磁盘。
  2. 应该为每个单独的任务使用 httpclient 还是应该共享一个？
  3. 事件是将下载的文件引用“发送”到视图模型的好方法吗？[我也会在codereview中发帖]
4

2 回答 2

2

如果您嵌入异步等待，您应该使用

Task.ConfigureAwait(false)

在任何返回 Task 的东西上，否则任务将在调用者的线程上下文中继续，除了 UI 线程之外，这是不必要的。总之，库应该使用 ConfigureAwait(false) 而 UI 代码不应该。就是这样！

于 2012-11-13T14:01:42.437 回答
0

我认为您的问题与您的代码没有直接关系，因此我将在这里回答：

在其他 Async/Await 方法中嵌入 Async/Await 有什么效果？（在 Async / Await 方法中将文件流写入磁盘。）

async方法旨在像这样组合。实际上，这是唯一的async-await可用于：组合异步方法以创建另一个异步方法。

await发生的情况是，如果您Task尚未完成，您的方法实际上会返回给调用者。然后，当Task完成时，您的方法会在原始上下文中恢复（例如 UI 应用程序中的 UI 线程）。

如果您不想继续使用原始上下文（因为您不需要它），您可以使用 更改它ConfigureAwait(false)，就像您已经做的那样。无需在内部执行此操作Task.Run()，因为该代码不在原始上下文中运行。

应该为每个单独的任务使用 httpclient 还是应该共享一个？

的文档HttpClient说它的实例方法不是线程安全的，所以你应该为每个Task.

事件是将下载的文件引用“发送”到视图模型的好方法吗？

我认为 events 不能很好地与async-结合在一起await。在您的情况下，它只有在您使用BindingOperations.EnableCollectionSynchronization并且也在您自己的代码中正确锁定集合时才有效。

我认为更好的选择是使用 TPL Dataflow 或 Rx 之类的东西。

于 2012-11-13T21:14:58.150 回答