程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#入門知識 >> C#之使用AutoResetEvent實現線程的順序執行

C#之使用AutoResetEvent實現線程的順序執行

編輯:C#入門知識

C#之使用AutoResetEvent實現線程的順序執行


前幾天一朋友問我如何實現線程的順序執行,說真的,雖然看過CLR這本書,也把線程部分拜讀了兩遍,但是這個問題出來之後還是沒有一個思路。今天在搜索資料的時候無意中再次看到AutoResetEvent這個東西,當然我知道它是和線程有關,用於處理線程切換之類的(可能在測試Demo之前理解有誤),於是決定用AutoResetEvent來處理上面的問題。   這裡以園區一個園友的例子來說明,這個例子就是 買書--》付款--》拿書這個過程,該過程會持續n(通過變量設置)次,並且每一次都要按照順序執行,有可能有同學會疑問,直接Sleep不就好了,干嘛非要多個線程,如果處理某一個環節的時間過久或者是業務復雜,那麼整個程序就直接未響應了,所以這裡加入多線程來保證程序的響應。    
class Program
    {
        //循環次數
        const int numIterations = 10;
        //買書
        static AutoResetEvent buyResetEvent = new AutoResetEvent(false);
        //付款
        static AutoResetEvent payResetEvent = new AutoResetEvent(false);
        //取書
        static AutoResetEvent getBookEvent = new AutoResetEvent(false);
       //循環的次數
        static int number;
        static void Main(string[] args)
        {
            //付款線程
            Thread payMoneyThread = new Thread(new ThreadStart(PayMoneyProc));
            payMoneyThread.Name = "付錢線程";

            //取書線程
            Thread getBookThread = new Thread(new ThreadStart(GetBookProc));
            getBookThread.Name = "取書線程";

            payMoneyThread.Start();
            getBookThread.Start();

            for (int i = 1; i <= numIterations; i++)
            {
                Console.WriteLine("買書線程:數量{0}", i);
                number = i;
                //允許付款線程等待
                payResetEvent.Set();
                //禁止買書線程等待
                buyResetEvent.WaitOne();
            }
            Console.Read();
        }

        static void PayMoneyProc()
        {
            while (true)
            {
                //等待付款
                payResetEvent.WaitOne();
                Console.WriteLine("{0}:數量{1}", Thread.CurrentThread.Name, number);
                //允許取書線程等待
                getBookEvent.Set();
            }
        }
        static void GetBookProc()
        {
            while (true)
            {
                //等待付款
                getBookEvent.WaitOne();     
                Console.WriteLine("{0}:數量{1}", Thread.CurrentThread.Name, number);
                Console.WriteLine("------------------------------------------");
                //允許買書線程等待(到這一步一個完整的買書流程就執行結束了,完全按照買書--》付款--》取書的流程)
                buyResetEvent.Set();
            }
        }
    }

 

  上述代碼不復雜,但是有幾個關鍵的對象和方法,接下來詳細進行說明。   1.分別定義了買書、付款、拿書三個AutoResetEvent,注意定義的時候傳入了false,這也AutoSet默認是不可用的,需要手動調用Set方法才可以呢。該對象是決定是否能WaitOne一個請求的關鍵,當AutoResetEvent.Set執行則可以使用AutoResetEvent.WaitOne進行一個等待請求,如果再有WaitOne請求,則要繼續等待Set的執行;   2.先看for循環,在循環中我們使用payResetEvent.Set()這句代碼,這也PayThread中的WaitOne請求就可以獲得批准(下文有介紹),同時我們又加上了buyResetEvent.WaitOne()(這樣在上一次購買流程結束之前,新的一次流程是不可以執行的,這也就是我們的最大問題,保證線程按照順序執行);   3.定義了付款和拿書的Thread,並且在方法內都是While循環,該循環主要是為了可以將我們的過程進行多次,畢竟線程只會執行一遍嘛。當然這個不是重點,重點是While中我們的操作,先看PayThrea的操作,先調用payResetEvent.WaitOne()請求一個等待操作,當然可以立馬執行,因為在 2 中我們說了for中是調用了payResetEvent.Set()操作,這樣就可以直接得到一個請求響應,輸出關鍵信息,然後又到了重點,我們調用了getBookEvent.Set(),這是為什麼呢,因為付款不成功是不可以拿書走的啊,那樣就是偷盜了。注意、注意、注意,重要的話說三遍,GetBookThread操作中也有一個waitOne請求,可是為什麼不會執行呢,因為沒有Set呢,我們初始化AutoResetEvent的時候我們設置的是false,這樣默認就不可以得到一個請求,必須手動調用Set才可以,由於在PayMoneyThread的最後一行代碼中我們調用了getBookEvent.Set(),這樣getBookEvent.WaitOne就可用了。在GetBookThread中依次輸出關鍵信息,最後一行代碼又來了,再次調用了一個AutoResetEvent.Set(),沒錯就是買書的對象,因為到了這一步完整的買書流程就結束了,可以再次買書了啊啊啊啊啊啊,可以買書了,好開心啊。然後再次回到for循環中的最後一行代碼,buyResetEvent.Wait()此時就復活了,開始第好幾次的買書流程。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved