如果有幾個Uri,需要獲取這些Uri的所有內容的長度之和,你會如何做?
很簡單,使用WebClient一個一個的獲取uri的內容長度,進行累加。
也就是說如果有5個Uri,請求的時間分別是:1s 2s 3s 4s 5s.
那么需要的時間是:1+2+3+4+5=(6*5)/2=15.
如果采用并行計算的話,結果可能是這樣:
總時間長度是5s.
為了演示效果,需要下面3個頁面:
其中SlowPage 的Page_load代碼如下:
protected void Page_Load(object sender, EventArgs e)
{
Thread.Sleep(5000);
}
VerySlowPage的Page_load事件則 Thread.Sleep(10000);
新建控制臺程序CAStudy:
首先新建類AsyncDemo:
同步的獲取Uris的內容長度代碼如下:
public class AsyncDemo
{
public int SumPageSizes(IList<Uri> uris)
{
int total = 0;
foreach (var uri in uris)
{
Console.WriteLine("Thread {0}:Found {1} bytes...{2}",
Thread.CurrentThread.ManagedThreadId, total,DateTime.Now);
var data = new WebClient().DownloadData(uri);
total += data.Length;
}
Console.WriteLine("{0}:Found {1} bytes total {2}",
Thread.CurrentThread.ManagedThreadId, total, DateTime.Now);
return total;
}
}
在這里SumPageSizes 方法,通過foreach循環(huán)一個一個的下載數(shù)據(jù)。
Main函數(shù)如下:
public static void Main()
{
List<Uri> uris = new List<Uri>();
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/QuickPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/SlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/VerySlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/QuickPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/SlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/VerySlowPage.aspx"));
AsyncDemo asyncDemo = new AsyncDemo();
int totalSize = asyncDemo.SumPageSizes(uris);
}
Main 函數(shù)主要是構造Uri,然后調用AsyncDemo的SumPageSizes方法來獲取所有Uri的內容的總長度。
結果如下:
可以看到時間分別是0s,5s,10s,0s ,5s,10s.所以總長度是(0+5+10)*2=30.
可以看到速度很慢,如果有一個網(wǎng)頁卡住的話,后面很恐怖的哦
下面演示使用async,await的方式:
第一步:將 VS2010 升級到 VS2010 sp1.
第二步:下載Async CTP,進行安裝
第三步:為應用程序添加AsyncCTPLibrary引用,如下:
OK,將上面的SumPageSizes 方法修改如下:
public async Task<int> SumPageSizesAsync2(IList<Uri> uris)
{
var tasks = uris.Select(uri => new WebClient().DownloadDataTaskAsync(uri));
var data = await TaskEx.WhenAll(tasks);
return await TaskEx.Run(() =>
{
return data.Sum(s => s.Length);
});
}
在AsyncCTPLibrary.dll中,微軟為一些類提供了擴展,如下:
WebClient的擴展如下:
可以看到基本上為每個Download 都增加了一個XXXTaskAsync 的擴展方法。
返回的全部都是Task,
為什么全部都是Task?,因為await 只能wait Task,并且await 只能用在async 標記的方法中,
async 關鍵字表明這是個異步方法。
第一句:
public async Task<int> SumPageSizesAsync(IList<Uri> uris)
因為我們申明的是一個異步方法,所以要使用async 關鍵字,SumPageSizesAsync方法返回的結果是int類型,所以返回Task<int>.
第二句:
IEnumerable<Task<Byte[]>> tasks = uris.Select(uri => new WebClient().DownloadDataTaskAsync(uri));
獲取DownloadDataTaskAsync返回的所有Task。
第三句:
byte[][] data = await TaskEx.WhenAll(tasks);
首先第二句返回的是IEnumerable<Task<Byte[]>> 類型,也就是一個一個的Task<Byte[]> 的任務,使用TaskEx的WhenAll方法可以將這些任務轉變成一個Task<Byte[][]> 的任務
使用await關鍵字意味著Task<Byte[][]> 方法需要等待,等待結束后返回Byte[][]。
第四句:
return await TaskEx.Run<int>(() =>
{
return data.Sum(s => s.Length);
});
TaskEx.Run 返回將使用第三句返回的data,將Byte[][] 的數(shù)據(jù)進行Sum運算,返回一個Task<int> 的對象,如果不使用await 的話:

因為 async 關鍵字代表的是異步方法,并且該異步方法返回的結果是int,所以需要再次使用await 關鍵字:
return await TaskEx.Run<int>(() =>
{
return data.Sum(s => s.Length);
});
修改Main代碼如下:
public static void Main()
{
List<Uri> uris = new List<Uri>();
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/QuickPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/SlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/VerySlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/QuickPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/SlowPage.aspx"));
uris.Add(new Uri("http://localhost:57815/AsyncTestPages/VerySlowPage.aspx"));
AsyncDemo asyncDemo = new AsyncDemo();
Console.WriteLine(DateTime.Now);
int totalSize = asyncDemo.SumPageSizesAsync(uris).Result;
Console.WriteLine("TotalSize:{0}, Finished", totalSize);
Console.WriteLine(DateTime.Now);
}
運行結果如下:
可以看到使用了16秒的時間,大致等于理論值15.
有的同學會說,很麻煩!,的確,我也感覺很麻煩,還不如ThreadPool 來的快,不過async,await主要并不是解決這類問題的,它所解決的是異步中的同步,也就是說在某些異步操作中,需要同步的去處理,比如在Silverlight中,
異步獲取A
主站蜘蛛池模板:
国产在线一
|
午夜一区二区三区在线观看
|
免费在线观看一级毛片
|
一区二区免费播放
|
久久精品视频免费
|
亚洲精品一区二区三区在线播放
|
久久国产一区二区三区
|
男人的天堂视频网站
|
亚洲国产精品一区
|
精久久久久久
|
久在草视频
|
成av在线
|
亚洲免费在线观看
|
日本天堂在线观看
|
欧美a区|
亚洲视频在线观看免费
|
91精品国产综合久久精品
|
超碰精品
|
吊视频一区二区三区
|
久久伊人av
|
久久这里只有精品23
|
日本久久久久久久久久
|
中文字幕乱码一区二区三区
|
亚洲精品乱码久久久久久按摩观
|
久久久激情
|
国产片久久
|
欧美日韩免费在线
|
91 在线观看
|
精品国产一区二区三区av片
|
欧美一区2区三区4区公司二百
|
av水蜜桃
|
欧美日日操
|
国产免费观看一区二区三区
|
亚州中文字幕蜜桃视频
|
色综合天天综合网国产成人网
|
一区二区三区国产
|
中文字幕一页二页
|
日韩久久久一区二区
|
成人一区视频
|
欧美在线一二三区
|
日日碰碰
|