1

複数の非同期httpリクエストを待つ方法についてお聞きしたいのですが。

私のコードは次のようなものです：

    public void Convert(XDocument input, out XDocument output)
    {
        var ns = input.Root.Name.Namespace;

        foreach (var element in input.Root.Descendants(ns + "a"))
        {
            Uri uri = new Uri((string)element.Attribute("href"));

            var wc = new WebClient();
            wc.OpenReadCompleted += ((sender, e) =>
            {
                element.Attribute("href").Value = e.Result.ToString();
            }
            );
            wc.OpenReadAsync(uri);
        }

        //I'd like to wait here until above async requests are all completed.
        output = input;  
    }

誰かがこれの解決策を知っていますか？

4

2 に答える 2

2

Scott Hanselman による記事があり、ノンブロッキング リクエストの実行方法について説明しています。その最後までスクロールすると、public Task<bool> ValidateUrlAsync(string url)方法があります。

このように変更できます（応答の読み取りについてはより堅牢になる可能性があります）

public Task<string> GetAsync(string url)
{
    var tcs = new TaskCompletionSource<string>();
    var request = (HttpWebRequest)WebRequest.Create(url);
    try
    {
        request.BeginGetResponse(iar =>
        {
            HttpWebResponse response = null;
            try
            {
                response = (HttpWebResponse)request.EndGetResponse(iar);
                using(var reader = new StreamReader(response.GetResponseStream()))
                {
                    tcs.SetResult(reader.ReadToEnd());
                }                    
            }
            catch(Exception exc) { tcs.SetException(exc); }
            finally { if (response != null) response.Close(); }
        }, null);
    }
    catch(Exception exc) { tcs.SetException(exc); }
    return tsc.Task; 
}

これを手にすると、次のように使用できます

var urls=new[]{"url1","url2"};
var tasks = urls.Select(GetAsync).ToArray();
var completed = Task.Factory.ContinueWhenAll(tasks,
                    completedTasks =>{
                                          foreach(var result in completedTasks.Select(t=>t.Result))
                                          {
                                              Console.WriteLine(result);
                                          }
                                      });
completed.Wait();
//anything that follows gets executed after all urls have finished downloading

これがあなたを正しい方向に導くことを願っています。

PS。これはおそらく、async/await を使用せずに取得できるのと同じくらい明確です

于 2012-05-26T13:15:09.570 に答える
1

継続渡しスタイルの使用を検討してください。このように Convert メソッドを再構築できれば、

public void ConvertAndContinueWith(XDocument input, Action<XDocument> continueWith)
{
    var ns = input.Root.Name.Namespace;
    var elements = input.Root.Descendants(ns + "a");
    int incompleteCount = input.Root.Descendants(ns + "a").Count;
    foreach (var element in elements)
    {
        Uri uri = new Uri((string)element.Attribute("href"));

        var wc = new WebClient();
        wc.OpenReadCompleted += ((sender, e) =>
        {
            element.Attribute("href").Value = e.Result.ToString();
            if (interlocked.Decrement(ref incompleteCount) == 0)
               // This is the final callback, so we can continue executing.
               continueWith(input);
        }
        );
        wc.OpenReadAsync(uri);
    }
}

次に、そのコードを次のように実行します。

XDocument doc = something;
ConvertAndContinueWith(doc, (finishedDocument) => {
    // send the completed document to the web client, or whatever you need to do
});
于 2012-05-26T12:47:14.773 に答える