浅谈.NET下的多线程和并行计算（十一）.NET异步编程模型基础 下

关注下ReadStream.BeginRead()的回调方法：

private　static　void　DownloadBitsReadCallback(IAsyncResult　result)
{
　　 DownloadBitsState　asyncState　=　(DownloadBitsState)result.AsyncState;
　　 DownloadBitsReadCallbackState(asyncState,　result);
}

继续看看DownloadBitsReadCallbackState：

private　static　void　DownloadBitsReadCallbackState(DownloadBitsState　state,　 IAsyncResult　result)
{
　　 Stream　readStream　=　state.ReadStream;
　　 Exception　exception　=　null;
　　 bool　flag　=　false;
　　 try
　　 {
　　　　 int　bytesRetrieved　=　0;
　　　　 if　((readStream　!=　null)　&&　(readStream　!=　Stream.Null))
　　　　 {

bytesRetrieved　=　readStream.EndRead(result);

　　　　 }
　　　　 flag　=　state.RetrieveBytes(ref　bytesRetrieved);
　　 }
　　 catch　(Exception　exception2)
　　 {
　　　　 flag　=　true;
　　　　 if　(((exception2　is　ThreadAbortException)　||　(exception2　is　 StackOverflowException))　||　(exception2　is　OutOfMemoryException))
　　　　 {
　　　　　　 throw;
　　　　 }
　　　　 exception　=　exception2;
　　　　 state.InnerBuffer　=　null;
　　　　 if　(!(exception2　is　WebException)　&&　!(exception2　is　 SecurityException))
　　　　 {
　　　　　　 exception　=　new　WebException(SR.GetString("net_webclient"),　 exception2);
　　　　 }
　　　　 AbortRequest(state.Request);
　　　　 if　((state　!=　null)　&&　(state.WriteStream　!=　null))
　　　　 {
　　　　　　 state.WriteStream.Close();
　　　　 }
　　 }
　　 finally
　　 {
　　　　 if　(flag)
　　　　 {
　　　　　　 if　(exception　==　null)
　　　　　　 {
　　　　　　　　 state.Close();
　　　　　　 }
　　　　　　 state.CompletionDelegate(state.InnerBuffer,　exception,　state.AsyncOp);
　　　　 }
　　 }
}