欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

C#多線(xiàn)程之線(xiàn)程同步WaitHandle

 更新時(shí)間:2022年03月21日 10:33:30   作者:.NET開(kāi)發(fā)菜鳥(niǎo)  
這篇文章介紹了C#多線(xiàn)程之線(xiàn)程同步WaitHandle的用法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

一、引言

在前面的文章中,我們是使用“鎖”的方式實(shí)現(xiàn)了線(xiàn)程間的通信,這種通信方式比較笨重。除了鎖之外,.NET中還提供了一些線(xiàn)程間更自由通訊的工具,他們提供了通過(guò)“信號(hào)”進(jìn)行通訊的機(jī)制,通俗的比喻為“開(kāi)門(mén)”、“關(guān)門(mén)”:Set()開(kāi)門(mén)、Reset()關(guān)門(mén)、WaitOne()等著。

二、WaitHandle

WaitHandle位于System.Threading命名空間下,是用來(lái)封裝等待對(duì)共享資源進(jìn)行獨(dú)占訪(fǎng)問(wèn)的操作系統(tǒng)特定的對(duì)象。WaitHandle是一個(gè)抽象類(lèi),我們一般不直接使用,而是使用它的派生類(lèi):

  • AutoResetEvent。
  • EventWaitHandle。
  • ManualResetEvent。
  • Mutex。
  • Semaphore。

1、AutoResetEvent

AutoResetEvent表示線(xiàn)程同步事件在一個(gè)等待線(xiàn)程釋放后收到信號(hào)時(shí)自動(dòng)重置。此類(lèi)不能被繼承。

是一個(gè)自動(dòng)阻塞,WaitOne()方法阻塞程序執(zhí)行,Set()方法釋放信息。當(dāng)釋放后阻塞的代碼繼續(xù)執(zhí)行。但下一次執(zhí)行還需要等待信號(hào)。

通俗來(lái)說(shuō),WaitOne()是關(guān)門(mén),Set()是開(kāi)門(mén)。但開(kāi)門(mén)之后,執(zhí)行完又自動(dòng)關(guān)門(mén),還需要開(kāi)門(mén)。可以知道超時(shí)時(shí)間:

// 設(shè)置超時(shí)時(shí)間為2秒,如果2秒后沒(méi)有信號(hào)程序繼續(xù)執(zhí)行
are.WaitOne(2000);

看下面的一個(gè)例子:

using System;
using System.Threading;

namespace AutoResetEventDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // 通過(guò)構(gòu)造函數(shù)創(chuàng)建,默認(rèn)是關(guān)門(mén)
            AutoResetEvent are = new AutoResetEvent(false);
            Thread t1 = new Thread(() => {
                while (true)
                {
                    Console.WriteLine("開(kāi)始等著開(kāi)門(mén)");
                    // 執(zhí)行完WaitOne之后自動(dòng)關(guān)門(mén)
                    are.WaitOne();
                    Console.WriteLine("又關(guān)門(mén)了");
                }
            });
            // 啟動(dòng)線(xiàn)程
            t1.Start();
            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadKey();
            //開(kāi)門(mén)
            are.Set();

            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadKey();
            //開(kāi)門(mén)
            are.Set();

            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadKey();
            //開(kāi)門(mén)
            are.Set();

            Console.ReadKey();
        }
    }
}

程序輸出結(jié)果:

舉一個(gè)形象點(diǎn)的例子,AutoResetEvent相當(dāng)于火車(chē)或者地鐵的閘機(jī)口,過(guò)了一個(gè)以后自動(dòng)關(guān)門(mén)。

2、ManualResetEvent

Manual表示手動(dòng)的??聪旅娴拇a:

using System;
using System.Threading;

namespace ManualResetEventDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // 通過(guò)構(gòu)造函數(shù)初始化
            // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén)
            ManualResetEvent mre = new ManualResetEvent(false);

            // 創(chuàng)建一個(gè)線(xiàn)程
            Thread t1 = new Thread(() => 
            {
                // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén)
                Console.WriteLine("開(kāi)始等著開(kāi)門(mén)");
                // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼
                mre.WaitOne();
                // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼
                Console.WriteLine("終于開(kāi)門(mén)了");
            });

            // 啟動(dòng)線(xiàn)程
            t1.Start();

            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadLine();
            // 調(diào)用開(kāi)門(mén)的方法
            mre.Set();

            Console.ReadKey();

        }
    }
}

運(yùn)行程序,什么也不輸入,看一下輸出結(jié)果:

我們隨意輸入,再看運(yùn)行結(jié)果:

怎么關(guān)門(mén)呢?關(guān)門(mén)也需要我們手動(dòng)的調(diào)用:

using System;
using System.Threading;

namespace ManualResetEventDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // 通過(guò)構(gòu)造函數(shù)初始化
            // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén)
            ManualResetEvent mre = new ManualResetEvent(false);

            // 創(chuàng)建一個(gè)線(xiàn)程
            Thread t1 = new Thread(() => 
            {
                // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén)
                Console.WriteLine("開(kāi)始等著開(kāi)門(mén)");
                // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼
                mre.WaitOne();
                // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼
                Console.WriteLine("終于開(kāi)門(mén)了");
            });

            // 啟動(dòng)線(xiàn)程
            t1.Start();

            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadLine();
            // 調(diào)用開(kāi)門(mén)的方法
            mre.Set();
            // 休眠3秒
            Thread.Sleep(3000);
            // 關(guān)門(mén)
            mre.Reset();
            Console.WriteLine("關(guān)門(mén)了");

            Console.ReadKey();

        }
    }
}

程序輸出結(jié)果:

WaitOne()方法還可以設(shè)置等待超時(shí)時(shí)間,超過(guò)了等待時(shí)間就不會(huì)再等了。如果不設(shè)置等待超時(shí)時(shí)間,那么就會(huì)一直等下去??聪旅娲a:

using System;
using System.Threading;

namespace ManualResetEventDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // 通過(guò)構(gòu)造函數(shù)初始化
            // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén)
            ManualResetEvent mre = new ManualResetEvent(false);

            //// 創(chuàng)建一個(gè)線(xiàn)程
            //Thread t1 = new Thread(() => 
            //{
            //    // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén)
            //    Console.WriteLine("開(kāi)始等著開(kāi)門(mén)");
            //    // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼
            //    mre.WaitOne();
            //    // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼
            //    Console.WriteLine("終于開(kāi)門(mén)了");
            //});

            // 創(chuàng)建一個(gè)線(xiàn)程
            Thread t1 = new Thread(() =>
            {
                // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén)
                Console.WriteLine("開(kāi)始等著開(kāi)門(mén)");
                // 設(shè)置超時(shí)等待時(shí)間為5秒鐘
                if(mre.WaitOne(5000))
                {
                    // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼
                    Console.WriteLine("終于開(kāi)門(mén)了");
                }
                else
                {
                    // 等待超時(shí)
                    Console.WriteLine("過(guò)了5秒鐘了還沒(méi)開(kāi)門(mén)");
                }
                
            });

            // 啟動(dòng)線(xiàn)程
            t1.Start();

            Console.WriteLine("按任意鍵開(kāi)門(mén)");
            Console.ReadLine();
            // 調(diào)用開(kāi)門(mén)的方法
            mre.Set();
            // 休眠3秒
            Thread.Sleep(3000);
            // 關(guān)門(mén)
            mre.Reset();
            Console.WriteLine("關(guān)門(mén)了");

            Console.ReadKey();

        }
    }
}

運(yùn)行程序,什么也不輸入,看運(yùn)行結(jié)果:

WaitHandle.WaitAll(WaitHandle[] waitHandles)用來(lái)等待所有信號(hào)都變?yōu)?ldquo;開(kāi)門(mén)狀態(tài)”,WaitHandle.WaitAny(WaitHandle[] waitHandles) 用來(lái)等待任意一個(gè)信號(hào)都變?yōu)?ldquo;開(kāi)門(mén)狀態(tài)”。

ManualResetEvent是一旦設(shè)定Set()后就一直開(kāi)門(mén),除非調(diào)用Reset()方法關(guān)門(mén)。

舉一個(gè)形象點(diǎn)的例子,ManualResetEvent就相當(dāng)于是學(xué)校的大門(mén),只要開(kāi)門(mén)以后大家都可以進(jìn)入,除非主動(dòng)關(guān)門(mén)(等于執(zhí)行了Reset()方法)。

到此這篇關(guān)于C#多線(xiàn)程之線(xiàn)程同步WaitHandle的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論