这个问题对如何执行异步有一个很好的答案HttpWebRequest
。
我有一个要使用此方法异步获取的 50k+ URL 的列表。我遇到的问题是主线程将在所有异步请求完成之前完成并退出。
我发现ManualResetEvent
可以用来WaitOne()
调用Set()
回调方法。如果我只做一个请求,这将非常有用。不确定如何处理许多请求。
这个问题对如何执行异步有一个很好的答案HttpWebRequest
。
我有一个要使用此方法异步获取的 50k+ URL 的列表。我遇到的问题是主线程将在所有异步请求完成之前完成并退出。
我发现ManualResetEvent
可以用来WaitOne()
调用Set()
回调方法。如果我只做一个请求,这将非常有用。不确定如何处理许多请求。
您可以使用 TPL:
using System;
using System.IO;
using System.Linq;
using System.Net;
using System.Threading.Tasks;
class Program
{
static void Main(string[] args)
{
var urls = new[]
{
"http://www.google.com",
"http://www.yahoo.com"
};
var tasks = urls.Select(url =>
{
var request = WebRequest.Create(url);
return Task
.Factory
.FromAsync<WebResponse>(request.BeginGetResponse, request.EndGetResponse, url)
.ContinueWith(t =>
{
if (t.IsCompleted)
{
using (var stream = t.Result.GetResponseStream())
using (var reader = new StreamReader(stream))
{
Console.WriteLine("-- Successfully downloaded {0} --", t.AsyncState);
Console.WriteLine(reader.ReadToEnd());
}
}
else if (t.IsFaulted)
{
Console.WriteLine("There was an error downloading {0} - {1}", t.AsyncState, t.Exception);
}
});
}).ToArray();
Task.WaitAll(tasks);
}
}