C#怎么實(shí)現(xiàn)線程通知

這篇文章主要介紹了C#怎么實(shí)現(xiàn)線程通知的相關(guān)知識，內(nèi)容詳細(xì)易懂，操作簡單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇C#怎么實(shí)現(xiàn)線程通知文章都會有所收獲，下面我們一起來看看吧。

AutoRestEvent 類用于從一個線程向另一個線程發(fā)送通知。

微軟文檔是這樣介紹的：表示線程同步事件在一個等待線程釋放后收到信號時自動重置。

其構(gòu)造函數(shù)只有一個：

構(gòu)造函數(shù)里面的參數(shù)用于設(shè)置信號狀態(tài)。

真糟糕的機(jī)器翻譯。

常用方法

AutoRestEvent 類是干嘛的，構(gòu)造函數(shù)的參數(shù)又是干嘛的？不著急，我們來先來看看這個類常用的方法：

一個簡單的示例

這里我們編寫一個這樣的程序：

創(chuàng)建一個線程，能夠執(zhí)行多個階段的任務(wù)；每完成一個階段，都需要停下來，等待子線程發(fā)生通知，才能繼續(xù)下一步執(zhí)行。

.WaitOne() 用來等待另一個線程發(fā)送通知；

.Set() 用來對線程發(fā)出通知，此時 AutoResetEvent 變成終止?fàn)顟B(tài)；

.ReSet() 用來重置 AutoResetEvent 狀態(tài)；

    class Program
    {
        // 線程通知
        private static AutoResetEvent resetEvent = new AutoResetEvent(false);

        static void Main(string[] args)
        {
            // 創(chuàng)建線程
            new Thread(DoOne).Start();

            // 用于不斷向另一個線程發(fā)送信號
            while (true)
            {
                Console.ReadKey();
                resetEvent.Set();           // 發(fā)生通知，設(shè)置終止?fàn)顟B(tài)
            }
        }

        public static void DoOne()
        {
            Console.WriteLine("等待中，請發(fā)出信號允許我運(yùn)行");

            // 等待其它線程發(fā)送信號
            resetEvent.WaitOne();

            Console.WriteLine("\n     收到信號，繼續(xù)執(zhí)行");
            for (int i = 0; i < 5; i++) Thread.Sleep(TimeSpan.FromSeconds(0.5));

            resetEvent.Reset(); // 重置為非終止?fàn)顟B(tài)
            Console.WriteLine("\n第一階段運(yùn)行完畢，請繼續(xù)給予指示");

            // 等待其它線程發(fā)送信號
            resetEvent.WaitOne();
            Console.WriteLine("\n     收到信號，繼續(xù)執(zhí)行");
            for (int i = 0; i < 5; i++) Thread.Sleep(TimeSpan.FromSeconds(0.5));

            Console.WriteLine("\n第二階段運(yùn)行完畢，線程結(jié)束，請手動關(guān)閉窗口");
        }
    }

解釋一下

AutoResetEvent 對象有終止和非終止?fàn)顟B(tài)。Set() 設(shè)置終止?fàn)顟B(tài)，Reset() 重置非終止?fàn)顟B(tài)。

這個終止?fàn)顟B(tài)，可以理解成信號已經(jīng)通知；非終止?fàn)顟B(tài)則是信號還沒有通知。

注意，注意終止?fàn)顟B(tài)和非終止?fàn)顟B(tài)指的是 AutoResetEvent 的狀態(tài)，不是指線程的狀態(tài)。

線程通過調(diào)用 WaitOne() 方法，等待信號；
另一個線程可以調(diào)用 Set() 通知 AutoResetEvent 釋放等待線程。
然后 AutoResetEvent 變?yōu)榻K止?fàn)顟B(tài)。

需要注意的是，如果 AutoResetEvent 已經(jīng)處于終止?fàn)顟B(tài)，那么線程調(diào)用 WaitOne() 不會再起作用。除非調(diào)用Reset() 。

構(gòu)造函數(shù)中的參數(shù)，正是設(shè)置這個狀態(tài)的。true 代表終止?fàn)顟B(tài)，false 代表非終止?fàn)顟B(tài)。如果使用 new AutoResetEvent(true); ，則線程一開始是無需等待信號的。

在使用完類型后，您應(yīng)直接或間接釋放類型，顯式調(diào)用 Close()/Dispose() 或 使用 using。 當(dāng)然，也可以直接退出程序。

需要注意的是，如果多次調(diào)用 Set() 的時間間隔過短，如果第一次 Set() 還沒有結(jié)束(信號發(fā)送需要處理時間)，那么第二次 Set() 可能無效(不起作用)。

復(fù)雜一點(diǎn)的示例

我們設(shè)計(jì)一個程序：

• Two 線程開始處于阻塞狀態(tài)；

• 線程 One 可以設(shè)置線程 Two 繼續(xù)運(yùn)行，然后阻塞自己；

• 線程 Two 可以設(shè)置 One 繼續(xù)運(yùn)行，然后阻塞自己；

程序代碼如下(運(yùn)行后，請將鍵盤設(shè)置成英文輸入狀態(tài)再按下按鍵)：

    class Program
    {
        // 控制第一個線程
        // 第一個線程開始時，AutoResetEvent 處于終止?fàn)顟B(tài)，無需等待信號
        private static AutoResetEvent oneResetEvent = new AutoResetEvent(true);

        // 控制第二個線程
        // 第二個線程開始時，AutoResetEvent 處于非終止?fàn)顟B(tài)，需要等待信號
        private static AutoResetEvent twoResetEvent = new AutoResetEvent(false);

        static void Main(string[] args)
        {
            new Thread(DoOne).Start();
            new Thread(DoTwo).Start();

            Console.ReadKey();
        }

        public static void DoOne()
        {
            while (true)
            {
                Console.WriteLine("\n① 按一下鍵，我就讓DoTwo運(yùn)行");
                Console.ReadKey();
                twoResetEvent.Set();
                oneResetEvent.Reset();
                // 等待 DoTwo() 給我信號
                oneResetEvent.WaitOne();

                Console.ForegroundColor = ConsoleColor.Green;
                Console.WriteLine("\n     DoOne() 執(zhí)行");
                Console.ForegroundColor = ConsoleColor.White;
            }
        }

        public static void DoTwo()
        {
            while (true)
            {
                Thread.Sleep(TimeSpan.FromSeconds(1));

                // 等待 DoOne() 給我信號
                twoResetEvent.WaitOne();

                Console.ForegroundColor = ConsoleColor.Yellow;
                Console.WriteLine("\n     DoTwo() 執(zhí)行");
                Console.ForegroundColor = ConsoleColor.White;

                Console.WriteLine("\n② 按一下鍵，我就讓DoOne運(yùn)行");
                Console.ReadKey();
                oneResetEvent.Set();
                twoResetEvent.Reset();
            }
        }
    }

解釋

兩個線程具有的功能：阻塞自己、解除另一個線程的阻塞。

用電影《最佳拍檔》里面的一個畫面來理解。

DoOne 、DoTwo 輪流呼吸，不能自己控制自己呼吸，但自己能夠決定別人呼吸。

你搞我，我搞你，就能相互呼吸了。

當(dāng)然WaitOne() 也可以設(shè)置等待時間，如果 光頭佬(DoOne) 耍賴不讓 金剛(DoTwo)呼吸，金剛等待一定時間后，可以強(qiáng)行蕩動天平，落地呼吸。

注意，AutoRestEvent 用得不當(dāng)容易發(fā)生死鎖。 
另外 AutoRestEvent 使用的是內(nèi)核時間模式，因此等待時間不能太長，不然比較耗費(fèi) CPU 時間。

AutoResetEvent 也適合用于線程同步。

另外，線程中使用 WaitOne() ，另一個線程使用 Set() 通知后， AutoResetEvent 對象會自動恢復(fù)非終止?fàn)顟B(tài)，不需要線程使用 Reset() 。

關(guān)于“C#怎么實(shí)現(xiàn)線程通知”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對“C#怎么實(shí)現(xiàn)線程通知”知識都有一定的了解，大家如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道。