C# 带有一个回调的多个异步 HttpRequest

Question

我想一次发出 10 个异步 http 请求，并且仅在所有请求完成后并在单个回调函数中处理结果。我也不想使用 WaitAll 阻塞任何线程（据我所知，WaitAll 会阻塞直到所有线程完成）。我想我想制作一个自定义 IAsyncResult 来处理多个调用。我走在正确的轨道上吗？是否有任何好的资源或示例来描述处理此问题？

Answer 1

我喜欢达林的解决方案。但是，如果你想要更传统的东西，你可以尝试这个。

我肯定会使用等待句柄数组和 WaitAll 机制：

static void Main(string[] args)
{

    WaitCallback del = state =>
    {
        ManualResetEvent[] resetEvents = new ManualResetEvent[10];
        WebClient[] clients = new WebClient[10];

        Console.WriteLine("Starting requests");
        for (int index = 0; index < 10; index++)
        {
            resetEvents[index] = new ManualResetEvent(false);
            clients[index] = new WebClient();

            clients[index].OpenReadCompleted += new OpenReadCompletedEventHandler(client_OpenReadCompleted);

            clients[index].OpenReadAsync(new Uri(@"http:\\www.google.com"), resetEvents[index]);
        }

        bool succeeded = ManualResetEvent.WaitAll(resetEvents, 10000);
        Complete(succeeded);

        for (int index = 0; index < 10; index++)
        {
            resetEvents[index].Dispose();
            clients[index].Dispose();
        }
    };

    ThreadPool.QueueUserWorkItem(del);

    Console.WriteLine("Waiting...");
    Console.ReadKey();
}

static void client_OpenReadCompleted(object sender, OpenReadCompletedEventArgs e)
{
    // Do something with data...Then close the stream
    e.Result.Close();

    ManualResetEvent readCompletedEvent = (ManualResetEvent)e.UserState;
    readCompletedEvent.Set();
    Console.WriteLine("Received callback");
}


static void Complete(bool succeeded)
{
    if (succeeded)
    {
        Console.WriteLine("Yeah!");
    }
    else
    {
        Console.WriteLine("Boohoo!");
    }
}

Answer 2

在 .NET 4.0 中，有一个很好的并行任务库 允许您执行以下操作：

using System;
using System.Linq;
using System.Net;
using System.Threading.Tasks;

class Program
{
    public static void Main()
    {
        var urls = new[] { "http://www.google.com", "http://www.yahoo.com" };

        Task.Factory.ContinueWhenAll(
            urls.Select(url => Task.Factory.StartNew(u => 
            {
                using (var client = new WebClient())
                {
                    return client.DownloadString((string)u);
                }
            }, url)).ToArray(), 
            tasks =>
            {
                var results = tasks.Select(t => t.Result);
                foreach (var html in results)
                {
                    Console.WriteLine(html);
                }
        });
        Console.ReadLine();
    }
}

正如您所看到的，对于列表中的每个 url，都会启动不同的任务，一旦所有任务完成，就会调用回调并传递所有任务的结果。

Answer 3

我认为你最好使用 WaitAll 方法。否则，您将处理 10 个 IAsyncResult 回调，并使用信号量确定所有 10 个回调最终完成。

请记住，WaitAll 非常高效；它不像线程“睡眠”那样愚蠢。当线程休眠时，它会继续使用处理时间。当线程因为命中 WaitAll 而被“取消调度”时，该线程将不再消耗任何处理器时间。这是非常有效的。