亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > C# > 正文

深入分析C#異步編程詳解

2020-01-24 03:18:42
字體:
來源:轉載
供稿:網友
同步方法和異步方法的區別
同步方法調用在程序繼續執行之前需要等待同步方法執行完畢返回結果
異步方法則在被調用之后立即返回以便程序在被調用方法完成其任務的同時執行其它操作
異步編程概覽
.NET Framework 允許您異步調用任何方法。定義與您需要調用的方法具有相同簽名的委托;公共語言運行庫將自動為該委托定義具有適當簽名
的 BeginInvoke 和 EndInvoke 方法。
BeginInvoke 方法用于啟動異步調用。它與您需要異步執行的方法具有相同的參數,只不過還有兩個額外的參數(將在稍后描述)。
BeginInvoke 立即返回,不等待異步調用完成。
BeginInvoke 返回 IasyncResult,可用于監視調用進度。
EndInvoke 方法用于檢索異步調用結果。調用 BeginInvoke 后可隨時調用 EndInvoke 方法;如果異步調用未完成,EndInvoke 將一直阻塞到
異步調用完成。EndInvoke 的參數包括您需要異步執行的方法的 out 和 ref 參數(在 Visual Basic 中為 <Out> ByRef 和 ByRef)以及由
BeginInvoke 返回的 IAsyncResult。
四種使用 BeginInvoke 和 EndInvoke 進行異步調用的常用方法。調用了 BeginInvoke 后,可以:
1.進行某些操作,然后調用 EndInvoke 一直阻塞到調用完成。
2.使用 IAsyncResult.AsyncWaitHandle 獲取 WaitHandle,使用它的 WaitOne 方法將執行一直阻塞到發出 WaitHandle 信號,然后調用
EndInvoke。這里主要是主程序等待異步方法,等待異步方法的結果。
3.輪詢由 BeginInvoke 返回的 IAsyncResult,IAsyncResult.IsCompeted確定異步調用何時完成,然后調用 EndInvoke。此處理個人認為與
相同。
4.將用于回調方法的委托傳遞給 BeginInvoke。該方法在異步調用完成后在 ThreadPool 線程上執行,它可以調用 EndInvoke。這是在強制裝
換回調函數里面IAsyncResult.AsyncState(BeginInvoke方法的最后一個參數)成委托,然后用委托執行EndInvoke。
警告   始終在異步調用完成后調用 EndInvoke。
以上有不理解的稍后可以再理解。
 
例子
1)先來個簡單的沒有回調函數的異步方法例子
請再運行程序的時候,仔細看注釋,對理解很有幫助。還有,若將注釋的中的兩個方法都同步,你會發現異步運行的速度優越性。
復制代碼 代碼如下:

using System;
 namespace ConsoleApplication1
 {
     class Class1
     {
         //聲明委托
         public delegate void AsyncEventHandler();

         //異步方法
         void Event1()
        {
            Console.WriteLine("Event1 Start");
            System.Threading.Thread.Sleep(4000);
            Console.WriteLine("Event1 End");
        }
        // 同步方法
        void Event2()
        {
            Console.WriteLine("Event2 Start");
            int i=1;
            while(i<1000)
            {
                i=i+1;
                Console.WriteLine("Event2 "+i.ToString());
            }
            Console.WriteLine("Event2 End");
        }
        [STAThread]
        static void Main(string[] args)
        {
            long start=0;
            long end=0;
            Class1 c = new Class1();
            Console.WriteLine("ready");
            start=DateTime.Now.Ticks;
            //實例委托
            AsyncEventHandler asy = new AsyncEventHandler(c.Event1);
            //異步調用開始,沒有回調函數和AsyncState,都為null
            IAsyncResult ia = asy.BeginInvoke(null, null);
            //同步開始,
            c.Event2();
            //異步結束,若沒有結束,一直阻塞到調用完成,在此返回該函數的return,若有返回值。

            asy.EndInvoke(ia);
            //都同步的情況。
            //c.Event1();
            //c.Event2();

            end =DateTime.Now.Ticks;
            Console.WriteLine("時間刻度差="+ Convert.ToString(end-start) );
            Console.ReadLine();
        }
    }
}

2)下面看有回調函數的WebRequest和WebResponse的異步操作。
復制代碼 代碼如下:

using System;
using System.Net;
using System.Threading;
using System.Text;
using System.IO;
// RequestState 類用于通過
// 異步調用傳遞數據
public class RequestState
{
    const int BUFFER_SIZE = 1024;
    public StringBuilder RequestData;
    public byte[] BufferRead;
    public HttpWebRequest Request;
    public Stream ResponseStream;
    // 創建適當編碼類型的解碼器
    public Decoder StreamDecode = Encoding.UTF8.GetDecoder();
    public RequestState()
    {
        BufferRead = new byte[BUFFER_SIZE];
        RequestData = new StringBuilder("");
        Request = null;
        ResponseStream = null;
    }
}
// ClientGetAsync 發出異步請求
class ClientGetAsync
{
    public static ManualResetEvent allDone = new ManualResetEvent(false);
    const int BUFFER_SIZE = 1024;
    public static void Main(string[] args)
    {
        if (args.Length < 1)
        {
            showusage();
            return;
        }
        // 從命令行獲取 URI
        Uri HttpSite = new Uri(args[0]);
        // 創建請求對象
        HttpWebRequest wreq = (HttpWebRequest)WebRequest.Create(HttpSite);
        // 創建狀態對象
        RequestState rs = new RequestState();
        // 將請求添加到狀態,以便它可以被來回傳遞
        rs.Request = wreq;
        // 發出異步請求
        IAsyncResult r = (IAsyncResult)wreq.BeginGetResponse(new AsyncCallback(RespCallback), rs);
        // 將 ManualResetEvent 設置為 Wait,
        // 以便在調用回調前,應用程序不退出
        allDone.WaitOne();
    }
    public static void showusage()
    {
        Console.WriteLine("嘗試獲取 (GET) 一個 URL");
        Console.WriteLine("/r/n用法::");
        Console.WriteLine("ClientGetAsync URL");
        Console.WriteLine("示例::");
        Console.WriteLine("ClientGetAsync http://www.microsoft.com/net/");
    }
    private static void RespCallback(IAsyncResult ar)
    {
        // 從異步結果獲取 RequestState 對象
        RequestState rs = (RequestState)ar.AsyncState;
        // 從 RequestState 獲取 HttpWebRequest
        HttpWebRequest req = rs.Request;
        // 調用 EndGetResponse 生成 HttpWebResponse 對象
        // 該對象來自上面發出的請求
        HttpWebResponse resp = (HttpWebResponse)req.EndGetResponse(ar);
        // 既然我們擁有了響應,就該從
        // 響應流開始讀取數據了
        Stream ResponseStream = resp.GetResponseStream();
        // 該讀取操作也使用異步完成,所以我們
        // 將要以 RequestState 存儲流
        rs.ResponseStream = ResponseStream;
        // 請注意,rs.BufferRead 被傳入到 BeginRead。
        // 這是數據將被讀入的位置。
        IAsyncResult iarRead = ResponseStream.BeginRead(rs.BufferRead, 0, BUFFER_SIZE, new AsyncCallback(ReadCallBack), rs);
    }
    private static void ReadCallBack(IAsyncResult asyncResult)
    {
        // 從 asyncresult 獲取 RequestState 對象
        RequestState rs = (RequestState)asyncResult.AsyncState;
        // 取出在 RespCallback 中設置的 ResponseStream
        Stream responseStream = rs.ResponseStream;
        // 此時 rs.BufferRead 中應該有一些數據。
        // 讀取操作將告訴我們那里是否有數據
        int read = responseStream.EndRead(asyncResult);
        if (read > 0)
        {
            // 準備 Char 數組緩沖區,用于向 Unicode 轉換
            Char[] charBuffer = new Char[BUFFER_SIZE];
            // 將字節流轉換為 Char 數組,然后轉換為字符串
            // len 顯示多少字符被轉換為 Unicode
            int len = rs.StreamDecode.GetChars(rs.BufferRead, 0, read, charBuffer, 0);
            String str = new String(charBuffer, 0, len);
            // 將最近讀取的數據追加到 RequestData stringbuilder 對象中,
            // 該對象包含在 RequestState 中
            rs.RequestData.Append(str);
            // 現在發出另一個異步調用,讀取更多的數據
            // 請注意,將不斷調用此過程,直到
            // responseStream.EndRead 返回 -1
            IAsyncResult ar = responseStream.BeginRead(rs.BufferRead, 0, BUFFER_SIZE, new AsyncCallback(ReadCallBack), rs);
        }
        else
        {
            if (rs.RequestData.Length > 1)
            {
                // 所有數據都已被讀取,因此將其顯示到控制臺
                string strContent;
                strContent = rs.RequestData.ToString();
                Console.WriteLine(strContent);
            }
            // 關閉響應流
            responseStream.Close();
            // 設置 ManualResetEvent,以便主線程可以退出
            allDone.Set();
        }
        return;
    }
}

在這里有回調函數,且異步回調中又有異步操作。
首先是異步獲得ResponseStream,然后異步讀取數據。
這個程序非常經典。從中可以學到很多東西的。我們來共同探討。
總結
上面說過,.net framework 可以異步調用任何方法。所以異步用處廣泛。
在.net framework 類庫中也有很多異步調用的方法。一般都是已Begin開頭End結尾構成一對,異步委托方法,外加兩個回調函數和AsyncState參數,組成異步操作的宏觀體現。所以要做異步編程,不要忘了委托delegate、Begin,End,AsyncCallBack委托,AsyncState實例(在回調函數中通過IAsyncResult.AsyncState來強制轉換),IAsycResult(監控異步),就足以理解異步真諦了。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
国产精品国产三级国产专播精品人| 欧美日韩国产一区中文午夜| 色哟哟入口国产精品| 国产精品对白刺激| 欧美性猛交xxxx免费看| 久久久免费观看| 中文字幕亚洲一区二区三区| 欧美日韩999| 在线观看精品国产视频| 国产精品高潮呻吟视频| 51精品国产黑色丝袜高跟鞋| 国产一区二区在线免费| 久久精品久久久久久国产 免费| 亚洲性猛交xxxxwww| 日本老师69xxx| 色妞一区二区三区| 久久九九精品99国产精品| www.美女亚洲精品| 日本欧美中文字幕| 中文字幕精品视频| 51ⅴ精品国产91久久久久久| 欧美电影第一页| 欧美激情精品久久久久| 久久躁日日躁aaaaxxxx| 麻豆国产精品va在线观看不卡| 午夜精品一区二区三区av| 国产精品扒开腿做爽爽爽视频| 欧美日韩性视频| 日产精品久久久一区二区福利| 亚洲国语精品自产拍在线观看| 另类专区欧美制服同性| 中文字幕国产日韩| 欧美久久精品一级黑人c片| 亚洲精品综合久久中文字幕| 成人美女免费网站视频| 欧美特黄级在线| 在线视频欧美日韩| 97欧美精品一区二区三区| 久久精品免费播放| 国产精品pans私拍| 日韩一区二区欧美| 久久久久国产视频| 国产精品∨欧美精品v日韩精品| 国内精品小视频| 精品亚洲一区二区三区在线播放| 日韩精品极品在线观看| 国产69精品久久久久9| 久久久久久久999| 中文.日本.精品| 欧美床上激情在线观看| www.欧美精品一二三区| 久久久亚洲国产| 57pao成人国产永久免费| 欧美精品久久久久久久| 全色精品综合影院| 精品高清美女精品国产区| 国产成人福利网站| 欧美精品九九久久| 亚洲国产天堂久久综合| 中文字幕日本精品| 26uuu另类亚洲欧美日本一| 69久久夜色精品国产7777| 97视频免费在线看| 第一福利永久视频精品| 91视频免费网站| 亚洲男子天堂网| 人妖精品videosex性欧美| 日韩精品在线影院| 最近2019免费中文字幕视频三| 91精品久久久久久久久青青| 国产精品日韩久久久久| 亚洲人在线观看| 国产盗摄xxxx视频xxx69| 亚洲伊人久久大香线蕉av| 高清日韩电视剧大全免费播放在线观看| 欧美国产中文字幕| xxx一区二区| 欧美性视频在线| 久久久噜噜噜久久中文字免| 中文字幕在线观看亚洲| 疯狂欧美牲乱大交777| 亚洲国产精品视频在线观看| 精品福利在线视频| 高潮白浆女日韩av免费看| 久久97精品久久久久久久不卡| 在线精品高清中文字幕| 亚洲国产精品va在线| 国产亚洲美女精品久久久| 欧美放荡办公室videos4k| 国产一区香蕉久久| 81精品国产乱码久久久久久| 国产在线视频91| 日韩经典第一页| 91av视频在线免费观看| 成人97在线观看视频| 亚洲影院色无极综合| 日韩美女毛茸茸| 狠狠色狠狠色综合日日小说| 国产成人一区二区三区小说| 久久69精品久久久久久国产越南| 亚洲一级片在线看| 国模叶桐国产精品一区| 成人性生交大片免费看小说| 宅男66日本亚洲欧美视频| 日韩成人在线免费观看| 国产91免费观看| 国产成人在线一区二区| 国产v综合v亚洲欧美久久| 亚洲成色777777在线观看影院| 国产精品日韩av| 亚洲性生活视频| 中文字幕日韩在线视频| 国产亚洲成精品久久| 欧美色视频日本高清在线观看| 久久天天躁夜夜躁狠狠躁2022| 国产亚洲欧美一区| 国产精品久久久久久久av大片| 亚洲高清一二三区| 亚洲精品第一国产综合精品| 久久久久久久一区二区三区| 日韩中文字幕视频在线观看| 亚洲丝袜一区在线| 青青久久aⅴ北条麻妃| 岛国av一区二区| 久久这里有精品视频| 久久久国产精品一区| 国产狼人综合免费视频| 亚洲精品视频网上网址在线观看| 久久免费少妇高潮久久精品99| 在线激情影院一区| 久久亚洲私人国产精品va| 欧美日韩成人在线视频| 久久亚洲精品小早川怜子66| 日韩中文字幕在线观看| 91精品中国老女人| 91麻豆桃色免费看| 欧美激情欧美激情| 亚洲成人激情在线观看| 欧美一区深夜视频| 精品自拍视频在线观看| 久久久久久亚洲| 亚洲香蕉成视频在线观看| 国产精品一久久香蕉国产线看观看| 日韩国产高清视频在线| 亚洲三级免费看| 亚洲第一免费播放区| 亚洲护士老师的毛茸茸最新章节| 国内精品久久影院| 欧美精品videossex性护士| 97香蕉超级碰碰久久免费软件| 国内精品久久久久影院 日本资源| 丁香五六月婷婷久久激情| 欧美激情一区二区三级高清视频| 51ⅴ精品国产91久久久久久| 国产视频亚洲精品| 国产成人一区二区三区电影| 91久久国产综合久久91精品网站| 欧美理论电影在线观看| 国内精品免费午夜毛片| 一区二区三区在线播放欧美| 中日韩美女免费视频网站在线观看| 国产日韩欧美一二三区| 成人午夜在线视频一区| 97人洗澡人人免费公开视频碰碰碰|