C# ManualResetEvent的理解和用法
ManualResetEvent是C#中一個(gè)比較常用的工具,可用于線程間通信,實(shí)現(xiàn)一種類似信號(hào)量的功能(不知道我這樣描述是否恰當(dāng),有可能不是“類似”,而“就是”通過(guò)信號(hào)量來(lái)實(shí)現(xiàn)的,因?yàn)槲乙彩亲罱胖肋@個(gè)類,以前一直不知道,哈哈。如果有哪位清楚的話,請(qǐng)給我解惑。)。
先了解一下ManualResetEvent的基本用法:
1、初始化:public ManualResetEvent(bool initialState);
ManualResetEvent的構(gòu)造方法有個(gè)bool型參數(shù),當(dāng)為true時(shí),則表示有信號(hào),為false時(shí),則表示無(wú)信號(hào)。這個(gè)怎么理解呢?我們接著看ManualResetEvent3個(gè)基本方法中的WaitOne方法。
2、WaitOne方法:WaitOne方法有幾種4種重載,我在這里只對(duì)它的功能進(jìn)行分析。
WaitOne方法,顧名思義,它會(huì)具有一種等待的功能,也就是線程阻塞。這里的阻塞功能是有條件的,當(dāng)無(wú)信號(hào)時(shí),它是阻塞的,有信號(hào)時(shí),它將無(wú)任何阻塞,被執(zhí)行時(shí)就直接跳過(guò)了(這個(gè)從邏輯上應(yīng)該挺好理解:當(dāng)有信號(hào)需要處理時(shí),需要立即處理,沒(méi)有任何信號(hào)時(shí),就當(dāng)然要等一等了)。所以,回顧到1,當(dāng)初始化ManualResetEvent時(shí),initialState為false,WaitOne將會(huì)有阻塞效果,否則,沒(méi)有阻塞效果。
3、Set方法:將ManualResetEvent對(duì)象的信號(hào)狀態(tài)設(shè)為有信號(hào)狀態(tài),這個(gè)時(shí)候WaitOne如果正在阻塞中的話,將會(huì)立即終止阻塞,向下繼續(xù)執(zhí)行。而且這個(gè)狀態(tài)一直不變的話,每次執(zhí)行到WaitOne都將無(wú)任何阻塞。
4、Reset方法:將ManualResetEvent對(duì)象的信號(hào)狀態(tài)設(shè)為無(wú)信號(hào)狀態(tài),當(dāng)下次執(zhí)行到WaitOne時(shí),又將重新開(kāi)始阻塞。
呵呵,按我個(gè)人理解,ManualResetEvent得幾個(gè)方法的功能大致就這個(gè)意思。嗯,口說(shuō)無(wú)憑,代碼才是王道。接下來(lái)我用一個(gè)生產(chǎn)消費(fèi)模型的例子來(lái)給大家班門弄斧一下!
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading;namespace ThreadTest {class Program{static void Main(string[] args){new ProductAndCostTester();}}/// <summary>/// 生產(chǎn)消費(fèi)模型/// </summary>public class ProductAndCostTester{/// <summary>/// 生產(chǎn)線1線程/// </summary>private Thread _producterThread1;/// <summary>/// 生產(chǎn)線2線程/// </summary>private Thread _producterThread2;/// <summary>/// 消費(fèi)線線程/// </summary>private Thread _costerThread;/// <summary>/// 產(chǎn)品列表/// </summary>private List<int> _goodList;/// <summary>/// ManualResetEvent實(shí)例/// </summary>private ManualResetEvent _mre;public ProductAndCostTester(){_goodList = new List<int>();_mre = new ManualResetEvent(false);//false初始化狀態(tài)為無(wú)信號(hào),將使WaitOne阻塞 _producterThread1 = new Thread(Product1);_producterThread1.Name = "Productor1";_producterThread1.Start();_producterThread2 = new Thread(Product2);_producterThread2.Name = "Productor2";_producterThread2.Start();_costerThread = new Thread(Cost);_costerThread.Name = "Costor";_costerThread.Start();}/// <summary>/// 生產(chǎn)線1/// </summary>void Product1(){while (true){Console.WriteLine(Thread.CurrentThread.Name + ":" + DateTime.Now.ToString("HH:mm:ss"));for (int i = 0; i < 3; i++){_goodList.Add(1);}_mre.Set();//表示有信號(hào)了,通知WaitOne不再阻塞 Thread.Sleep(8000);}}/// <summary>/// 生產(chǎn)線2/// </summary>void Product2(){while (true){Console.WriteLine(Thread.CurrentThread.Name + ":" + DateTime.Now.ToString("HH:mm:ss"));for (int i = 0; i < 6; i++){_goodList.Add(1);}_mre.Set();//表示有信號(hào)了,通知WaitOne不再阻塞 Thread.Sleep(10000);}}/// <summary>/// 消費(fèi)線/// </summary>void Cost(){while (true){if (_goodList.Count > 0){Console.WriteLine("Cost " + _goodList.Count + " at " + DateTime.Now.ToString("HH:mm:ss"));_goodList.Clear();_mre.Reset();//重置為無(wú)信號(hào)了,使WaitOne可以再次阻塞 }else{Console.WriteLine("No cost at " + DateTime.Now.ToString("HH:mm:ss"));_mre.WaitOne();//如果沒(méi)有可消費(fèi)的產(chǎn)品,即無(wú)信號(hào),則會(huì)阻塞 }}}} }這個(gè)代碼是可以直接運(yùn)行的,我就不再用附件了。嗯,下面我來(lái)簡(jiǎn)單講解一下我這個(gè)代碼想表達(dá)什么:
這里有3個(gè)線程,2條生產(chǎn)線和1條消費(fèi)線。2條生產(chǎn)線同時(shí)進(jìn)行,但是可能生產(chǎn)的速度不一致(這里一個(gè)8s/次,一個(gè)10s/次)。而另外一個(gè)消費(fèi)線程也是與生產(chǎn)線同時(shí)運(yùn)行的,我想實(shí)現(xiàn)一個(gè)目標(biāo):每當(dāng)有產(chǎn)品可以消費(fèi)時(shí),我將立即消費(fèi),不想有任何延遲。
按照以前最簡(jiǎn)單常用的思路,就是讓消費(fèi)線程每次運(yùn)行sleep一下,但是這個(gè)需要循環(huán)時(shí)間足夠短、循環(huán)頻率足夠快才行,頻率至少要高于任意一個(gè)生產(chǎn)線程,即sleep時(shí)間小于生產(chǎn)線程中sleep時(shí)間的最小值。
如果這樣實(shí)現(xiàn),代碼從邏輯來(lái)講是沒(méi)有任何問(wèn)題的,但是效率太低了,而且可能遭遇麻煩。假設(shè)這樣一種情況,如果生產(chǎn)線程的生產(chǎn)頻率是不固定的(不像我們這固定sleep幾秒鐘,這個(gè)在真實(shí)情況中是存在的),有時(shí)候1小時(shí)才生產(chǎn)一次,有時(shí)候100毫秒生產(chǎn)一次(笑,這個(gè)比較極端啊),那么我們至少需要將消費(fèi)線程的sleep時(shí)間低于100毫秒才行。這樣的話當(dāng)生產(chǎn)線程1個(gè)小時(shí)一次的時(shí)候是不是也太浪費(fèi)了,基本上消費(fèi)線程在空轉(zhuǎn)。
所以嘛,才有了我這樣一個(gè)代碼,我的消費(fèi)線程每次循環(huán)都會(huì)檢查已經(jīng)生產(chǎn)出來(lái)的產(chǎn)品數(shù)量,當(dāng)有產(chǎn)品可供消費(fèi)的時(shí)候,我就一次消費(fèi)光,并且提醒:“已經(jīng)沒(méi)有可消費(fèi)的產(chǎn)品了,下次可能需要等等了!”(調(diào)用Reset方法),那么下次循環(huán)時(shí),檢查到果然沒(méi)有產(chǎn)品了,那么就將等待了(WaitOne方法阻塞)。這時(shí)候消費(fèi)線程就會(huì)完全停在這了,不會(huì)每次都空轉(zhuǎn),是不是比較人性化?呵呵。
接下來(lái),任意一個(gè)生產(chǎn)線程如果生產(chǎn)出新的產(chǎn)品,就將會(huì)通知消費(fèi)線程:“嘿,伙計(jì),你要的東西來(lái)了,快醒醒吧!”(調(diào)用Set方法),這樣消費(fèi)線程就會(huì)立馬繼續(xù)運(yùn)行(WaitOne方法將會(huì)繼續(xù)向下執(zhí)行,并且在再次Reset前,它都不會(huì)再阻塞了)。當(dāng)然,消費(fèi)線程得下次循環(huán)將檢測(cè)到有產(chǎn)品可供消費(fèi)了,它又會(huì)將產(chǎn)品消費(fèi)完,并且又提醒:“已經(jīng)沒(méi)有可消費(fèi)的產(chǎn)品了,下次可能需要等等了!”(調(diào)用Reset方法)。就這樣生命不息,循環(huán)往復(fù)。
轉(zhuǎn)載于:https://www.cnblogs.com/modify/archive/2013/01/10/2855014.html
總結(jié)
以上是生活随笔為你收集整理的C# ManualResetEvent的理解和用法的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: 八杯水微博程序演示及下载
- 下一篇: 人民的胜利 爱奇艺黄金VIP恢复720P