在控制台应用程序中等待异步操作结束时，如何避免出现 Thread.Sleep(Int32.MaxValue)？

Question

我有以下代码，它将异步下载文件到我的硬盘驱动器，向控制台喊出当前进度并最终以告别消息退出：

webClient.DownloadProgressChanged.Add(fun args ->
      if (currentPercentage < args.ProgressPercentage) then
        Console.WriteLine(args.ProgressPercentage.ToString() + "%")

      currentPercentage <- args.ProgressPercentage
  )

webClient.DownloadFileCompleted.Add(fun args ->
  Console.WriteLine("Download finished!")
  Environment.Exit 0
)

webClient.DownloadFileAsync(new Uri(url_to_download),  file_name)

Thread.Sleep Int32.MaxValue

不过，我想知道是否有更优雅的方式来实现这无需在主线程中诉诸“永远休眠”，让程序通过 Environment.Exit() 结束。我对使用 Environment.Exit() 没有偏见，但如果可能的话，我想避免它！我能想到避免这种情况的唯一方法是生成一个新线程，然后等待它死亡，但这看起来确实很麻烦。有更简单的方法来实现这一点吗？

Answer 1

您可以像这样使用 ResetEvent：

webClient.DownloadProgressChanged += (f,a) => ...
AutoResetEvent resetEvent = new AutoResetEvent(false);
webClient.DownloadFileCompleted += (f, a) => resetEvent.Set();
webClient.DownloadDataAsync(new Uri(url_to_download), file_name);
resetEvent.WaitOne();
Console.WriteLine("Finished");

Answer 2

只需使用 waithandle 派生类（如 mutex 来发出信号）你已经准备好关门了。在下载完成的方法中发出信号，并在应用程序结束时等待它。当它发出信号时，您的应用程序将自然退出。

Answer 3

如果您是反应式扩展库（Rx）的粉丝，那么这个过程可以根据可观察的方式进行建模，例如：

    public static IObservable<int> DownloadURL(string url,string fname)
    {
        return Observable.Defer(() =>
        {
            var sub = new Subject<int>();
            var wc = new WebClient();
            wc.DownloadProgressChanged += delegate(object sender, DownloadProgressChangedEventArgs e)
            {
                sub.OnNext(e.ProgressPercentage);
                if (e.ProgressPercentage == 100)
                    sub.OnCompleted();
            };
            wc.DownloadFileAsync(new Uri(url), fname);
            return sub;
        });
    }

    public static void Main(string[] str)
    {
        foreach (var i in DownloadURL("http://www.google.com", "g:\\google.html").DistinctUntilChanged().ToEnumerable())
            Console.WriteLine(i);
    }

Answer 4

在 C# 中，您可以为 WebClient 编写一个扩展方法，等待下载完成，同时仍然推送更新事件：

static class WebClientEx {
    public static void DownloadSemiSync(this WebClient webClient, Uri address, string filename) {
        var evt = new AutoResetEvent(false);
        webClient.DownloadFileCompleted += (s, e) => evt.Set();
        webClient.DownloadFileAsync(address, filename);
        evt.WaitOne();
    }
}

这将允许您定义您想要的任何进度事件，然后将其用作同步函数，从而减少您的 main代码如下：

    static void Main() {
        var webClient = new WebClient();
        webClient.DownloadProgressChanged += (s, args) => {..};
        webClient.DownloadSemiSync(new Uri("http://.."), "test.bin");
        Console.WriteLine("DownloadFinished");
    }

抛出所有事件，但然后等待退出。