其中是VS11中的WebClient.DownloadStringTaskAsync(Uri,CancellationT

本文关键字:Uri CancellationT DownloadStringTaskAsync WebClient VS11 中的 | 更新日期: 2023-09-27 18:28:01

在异步CTP中,有一个带有签名的扩展方法

WebClient.DownloadStringTaskAsync(Uri,CancellationToken) 

VS11中的这个在哪里
我需要安装异步CTP才能获得此方法吗?

其中是VS11中的WebClient.DownloadStringTaskAsync(Uri,CancellationT

在.NET 4.5中,您可能会使用新的HttpClient类,特别是GetStringAsync方法。

不幸的是,没有内置CancellationToken支持,但以下是如何通过利用Register和CancelAsync方法来近似它:

var downloadTask = webClient.DownloadStringTaskAsync(source);
string text;
using (cancellationToken.Register(() => webClient.CancelAsync()))
{
    text = await downloadTask;
}

它仍然存在于.Net 4.5测试版中,请参阅MSDN,只是它不再是一个扩展方法。

您可能指的是WebClient未包含在.Net中用于Metro风格的应用程序。在那里,您可能应该使用HttpClient。另一种选择是使用HttpWebRequest,它仍然存在,并且已经用基于Task的异步方法进行了扩展。

类System.Net.WebClient和System.Net.Http.HttpClient都有一个异步函数。这使您能够创建一个异步函数。当GetStringAsync函数异步运行时,您可以定期检查是否请求取消。

示例:使用System.Net.Http;类HttpSonnetFetcher{const string sonnetsShakespeare=@"http://www.gutenberg.org/cache/epub/1041/pg1041.txt";

    public async Task<IEnumerable<string>> Fetch(CancellationToken token)
    {
        string bookShakespeareSonnets = null;
        using (var downloader = new HttpClient())
        {
            var downloadTask = downloader.GetStringAsync(sonnetsShakespeare);
            // wait until downloadTask finished, but regularly check if cancellation requested:
            while (!downloadTask.Wait(TimeSpan.FromSeconds(0.2)))
            {
                token.ThrowIfCancellationRequested();
            }
            // if still here: downloadTask completed
            bookShakespeareSonnets = downloadTask.Result;
        }
        // just for fun: find a nice sonnet, remove the beginning, split into lines and return 12 lines
        var indexNiceSonnet = bookShakespeareSonnets.IndexOf("Shall I compare thee to a summer's day?");
        return bookShakespeareSonnets.Remove(0, indexNiceSonnet)
            .Split(new char[] { ''r', ''n' }, StringSplitOptions.RemoveEmptyEntries)
            .Take(12);  
    }
}

用途如下:

private void TestCancellationHttpClient()
{
    try
    {
        var sonnetFetcher = new HttpSonnetFetcher();
        var cancellationTokenSource = new CancellationTokenSource();
        var sonnetTask = Task.Run(() => sonnetFetcher.Fetch(cancellationTokenSource.Token));
        cancellationTokenSource.CancelAfter(TimeSpan.FromSeconds(10));
        // meanwhile do something else, checking regularly if the task finished, or if you have nothing to do, just Task.Wait():
        while (!sonnetTask.Wait(TimeSpan.FromSeconds(0.25)))
        {
            Console.Write('.');
        }
        // if still here: the sonnet is fetched. return value is in sonnetTask.Result
        Console.WriteLine("A nice sonnet by William Shakespeare:");
        foreach (var line in sonnetTask.Result)
        {
            Console.WriteLine(line);
        }
    }
    catch (OperationCanceledException exc)
    {
        Console.WriteLine("Canceled " + exc.Message);
    }
    catch (AggregateException exc)
    {
        Console.WriteLine("Task reports exceptions");
        var x = exc.Flatten();
        foreach (var innerException in x.InnerExceptions)
        {
            Console.WriteLine(innerException.Message);
        }
    }
    catch (Exception exc)
    {
        Console.WriteLine("Exception: " + exc.Message);
    }
}

在一个简单的控制台程序中尝试一下,看看十四行诗是否正确提取,将CancelAfter从10秒减少到0.1秒,看看任务是否正确取消。

Nota-Bene:虽然抛出了OperationCancelledException,但此异常被包装为AggregateException的内部异常。任务中发生的所有异常始终包装在AggregateException中。