[.Net線程處理系列]專題五:線程同步——事件構造

引言:

??? 其實這部分內容應該是屬于專題四,因為這篇也是講關于線程同步的,但是由于考慮到用戶的閱讀習慣問題,因為文章太長了,很多人不是很愿意看包括我也是這樣的,同時也有和我說可以把代碼弄成折疊的,這樣就不會太長的,但是我覺得這樣也不怎么便于閱讀,因為我看別人的博客的時候,看到有代碼是折疊起來的時候很多時候不愿意去點,并且點一下之后同樣拉長文章的,然后就看到右邊的滾動條變小了,本以為快看完了(意思快學到知識了),一看滾動條后發現還有好長的內容很看, 所以就會給人一種不舒服的感覺吧(如果有和我一樣的人的話,你肯定懂的是什么感覺的)。所以我把線程同步放到兩篇文章里面來說,其實放到兩篇文章里面也有一定原因的, 前面講的線程同步主要是用戶模式的(CLR Via C# 一書中是這么定義的,書中說到線程同步分兩種:一、用戶模式構造 二、內核模式構造,第一次看的時候不是很理解兩個名詞是什么意思的,我一般理解東西是采用把東西拆分來理解,理解拆分的各個部分后再合起來理解內容的,現在我對著兩個的理解是——用戶模式構造:對于內核模式構造(指的的是構造操作系內核對象),我們使用類(.net Framework中的類,如 AutoResetEvent, Semaphore類)的方法來實現線程同步,其實內部是調用操作系統的內核對象來實現的線程同步,此時就會導致線程從托管代碼到為內核代碼,然而用戶模式構造,沒有調用操作系統內核對象,線程只是在用戶的托管代碼上執行的),對于用戶模式構造和內核模式的構造只是我自己的理解的, 如果有更好的理解方式可以留言告訴下我, 這樣我們可以一起討論和學習了。

?

目錄

一、WaitHandle基類介紹

二、事件(Event)類實現線程同步

三、小結

?

一、WaitHandle基類介紹

System.Threading命名空間中提供了一個WaitHandle?的抽象基類,此類就是包裝了一個Windows內核對象的句柄(句柄可以理解為標示了對象實例的一個數字,具體大家可以查看資料深入理解下的,在這里只是提出理解句柄也是很重要的),在.net Framework中提供了從WaitHandle類中派生的類(我正是用這些派生類在我們的代碼中實現線程同步的)。它們的一個繼承關系為

WaitHandle

  EventWaitHandle

  AutoResetEvent

    ManualResetEvent

  Semaphore

  Mutex

當我們在使用?AutoResetEvent,ManualResetEvent,Semaphore,Mutex這些類的時候,用構造函數來實例化這些類的對象時,其內部都調用了Win32 CreateEvent或CreateEvent函數,或CreateSemaphore或者CreateMutex函數,這些函數調用返回的句柄值都保存在WaitHandle基類定義的SafeWaitHandle字段中。

二、事件(Event)類實現線程同步

2.1?AutoResetEvent?(自動重置事件)

先講講AutoresetEvent類的構造函數,其定義為:

public AutoResetEvent(bool initialState);

構造函數中用一個bool 類型的初始狀態來設置AutoResetEvent對象的狀態,如果要將AutoResetEvent對象的初始狀態設置為終止,則傳入bool值為true,若要設置非終止,就傳入false。

WaitOne方法定義:

public virtual bool WaitOne(int millisecondsTimeout);該方法用來阻塞線程,當在指定的時間間隔還沒有收到一個信號時,將返回false。

調用Set方法發信號來釋放等待線程。在使用過程中WaitOne方法和Set方法都是成對出現的, 一個用于阻塞線程,等待信號,一個用來釋放等待線程(就是說調用set方法來發送一個信號,此時WaitOne接受到信號,就釋放阻塞的線程,線程就可以繼續運行)

線程通過調用AutoResetEvent的WaitOne方法來等待信號,如果AutoResetEvent對象為非終止狀態,則線程被阻止,等到線程調用Set方法來恢復線程執行。如果AutoResetEvent為終止狀態時,則線程不會被阻止,此時AutoResetEvent將立即釋放線程并返回為非終止狀態(指出有線程在使用資源的一種狀態)。

下面通過通過一個例子來演示下AutoResetEvent的使用:

 
  1. using?System; ?
  2. using?System.Threading; ?
  3. ?
  4. namespace?KenelMode ?
  5. { ?
  6. ????class?Program ?
  7. ????{ ?
  8. ????????//?初始化自動重置事件,并把狀態設置為非終止狀態 ?
  9. ????????//?如果這里把初始狀態設置為True時, ?
  10. ????????//?當調用WaitOne方法時就不會阻塞線程,看到的輸出結果的時間就是一樣的了 ?
  11. ????????//?因為設置為True時,表示此時已經為終止狀態了。??????? ?
  12. ????????public?static?AutoResetEvent?autoEvent?=?new?AutoResetEvent(false); ?
  13. ????????static?void?Main(string[]?args) ?
  14. ????????{ ?
  15. ????????????Console.WriteLine("Main?Thread?Start?run?at:?"?+DateTime.Now.ToLongTimeString()); ?
  16. ????????????Thread?t?=?new?Thread(TestMethod); ?
  17. ????????????t.Start(); ?
  18. ?
  19. ????????????//?阻塞主線程3秒后 ?
  20. ????????????//?調用?Set方法釋放線程,使線程t可以運行 ?
  21. ????????????Thread.Sleep(3000); ?
  22. ?
  23. ????????????//?Set?方法就是把事件狀態設置為終止狀態。 ?
  24. ????????????autoEvent.Set(); ?
  25. ????????????Console.Read(); ?
  26. ????????} ?
  27. ?
  28. ????????public?static?void?TestMethod() ?
  29. ????????{ ?
  30. ????????????autoEvent.WaitOne(); ?
  31. ?
  32. ????????????//?3秒后線程可以運行,所以此時顯示的時間應該和主線程顯示的時間相差3秒 ?
  33. ????????????Console.WriteLine("Method?Restart?run?at:?"?+?DateTime.Now.ToLongTimeString()); ?
  34. ????????} ?
  35. ????} ?
  36. }?

運行結果(從運行結果看確實是過了一秒后在TestMethod方法中的語句):

?上面中用到的是沒有帶參數的WaitOne方法,該方法表示無限制阻塞線程,直到收到一個事件為止(通過Set方法來發送一個信號),同時我們也可以設置堵塞線程的事件,當超時時,線程將不阻塞直接運行(盡管此時沒有通過Set來發送一個信號,線程照樣運行,只是WaitOne方法返回的的值不一樣)。

bool WaitOne(int millisecondsTimeout)?收到信號時返回為True,沒收到信號返回為false。

看完下面的代碼你可能會形象理解WaitOne(millisecondsTimeout)方法的使用的:

 
  1. using?System; ?
  2. using?System.Threading; ?
  3. ?
  4. namespace?KenelMode ?
  5. { ?
  6. ????class?Program ?
  7. ????{ ?
  8. ????????//?初始化自動重置事件,并把狀態設置為非終止狀態 ?
  9. ????????//?如果這里把初始狀態設置為True時, ?
  10. ????????//?當調用WaitOne方法時就不會阻塞線程,看到的輸出結果的時間就是一樣的了 ?
  11. ????????//?因為設置為True時,表示此時已經為終止狀態了。??????? ?
  12. ????????public?static?AutoResetEvent?autoEvent?=?new?AutoResetEvent(false); ?
  13. ????????static?void?Main(string[]?args) ?
  14. ????????{ ?
  15. ????????????Console.WriteLine("Main?Thread?Start?run?at:?"?+DateTime.Now.ToLongTimeString()); ?
  16. ????????????Thread?t?=?new?Thread(TestMethod); ?
  17. ????????????t.Start(); ?
  18. ?
  19. ????????????//?阻塞主線程1秒后 ?
  20. ????????????//?調用?Set方法釋放線程,使線程t可以運行 ?
  21. ????????????Thread.Sleep(3000); ?
  22. ?
  23. ????????????//?Set?方法就是把事件狀態設置為終止狀態。 ?
  24. ????????????autoEvent.Set(); ?
  25. ????????????Console.Read(); ?
  26. ????????} ?
  27. ?
  28. ????????public?static?void?TestMethod() ?
  29. ????????{ ?
  30. ????????????if?(autoEvent.WaitOne(2000)) ?
  31. ????????????{ ?
  32. ????????????????Console.WriteLine("Get?Singal?to?Work"); ?
  33. ????????????????//?3秒后線程可以運行,所以此時顯示的時間應該和主線程顯示的時間相差一秒 ?
  34. ????????????????Console.WriteLine("Method?Restart?run?at:?"?+?DateTime.Now.ToLongTimeString()); ?
  35. ????????????} ?
  36. ????????????else?
  37. ????????????{ ?
  38. ????????????????Console.WriteLine("Time?Out?to?work"); ?
  39. ????????????????Console.WriteLine("Method?Restart?run?at:?"?+?DateTime.Now.ToLongTimeString()); ?
  40. ????????????} ?
  41. ????????} ?
  42. ????} ?
  43. }?
運行結果:

同時這里可以把Thread.Sleep(3000)改成Thread.Sleep(1000)的時候,就是說AutoResetEvent對象在超時之前就接到信號了, 此時WaitOne(2000)放回的值就是True,就得到的是Get Singal to Work, 之間的事件間隔當然也是1秒了,在這里結果就不貼了。

2.2 ManualResetEvent(手動重置事件)

ManualResetEvent的使用和AutoResetEvent的使用很類似,因為他們都是從EventWaitHandle類派生的,不過他們還是有點區別:

AutoResetEvent?為終止狀態時線程調用 WaitOne,則線程不會被阻止。AutoResetEvent?將立即釋放線程并返回到非終止狀態,當再次調用WaitOne狀態時線程會被阻止

這里請注意如果AutoResetEvent初始為非終止狀態時, 調用WaitOne(int millisecondsTimeout)方法后并不會把狀態返回為終止狀態,此時還是非終止的,調用WaitOne方法自動改變狀態只針對初始狀態為終止狀態時有效。

然而ManualResetEvent初始狀態為終止狀態時時調用WaitOne,則線程同樣不會被阻止,但是ManualResetEvent的狀態不會發生改變(當我再次調用WaitOne方法是一樣不會阻止線程),需要我們手動終止()

下面通過一段代碼來說明兩者的區別:

 
  1. using?System; ?
  2. using?System.Threading; ?
  3. ?
  4. namespace?ManualResetEventSample ?
  5. { ?
  6. ????class?Program ?
  7. ????{ ?
  8. ????????//?初始化自動重置事件,并把狀態設置為終止狀態 ?
  9. ????????public?static?AutoResetEvent?autoEvent?=?new?AutoResetEvent(true); ?
  10. ?
  11. ????????public?static?ManualResetEvent?autoEvent?=?new?ManualResetEvent(true); ?
  12. ????????static?void?Main(string[]?args) ?
  13. ????????{ ?
  14. ????????????Console.WriteLine("Main?Thread?Start?run?at:?"?+?DateTime.Now.ToLongTimeString()); ?
  15. ????????????Thread?t?=?new?Thread(TestMethod); ?
  16. ????????????t.Start(); ?
  17. ????????????Console.Read(); ?
  18. ????????} ?
  19. ?
  20. ????????public?static?void?TestMethod() ?
  21. ????????{ ?
  22. ????????????//?初始狀態為終止狀態,則第一次調用WaitOne方法不會堵塞線程 ?
  23. ????????????//?此時運行的時間間隔應該為0秒,但是因為是AutoResetEvent對象 ?
  24. ????????????//?調用WaitOne方法后立即把狀態返回為非終止狀態。 ?
  25. ????????????autoEvent.WaitOne(); ?
  26. ????????????Console.WriteLine("Method?start?at?:?"+?DateTime.Now.ToLongTimeString()); ?
  27. ?
  28. ????????????//?因為此時AutoRestEvent為非終止狀態,所以調用WaitOne方法后將阻塞線程1秒,這里設置了超時時間 ?
  29. ????????????//?所以下面語句的和主線程中語句的時間間隔為1秒 ?
  30. ????????????//?當時?ManualResetEvent對象時,因為不會自動重置狀態 ?
  31. ????????????//?所以調用完第一次WaitOne方法后狀態仍然為非終止狀態,所以再次調用不會阻塞線程,所以此時的時間間隔也為0 ?
  32. ????????????//?如果沒有設置超時時間的話,下面這行語句將不會執行 ?
  33. ????????????autoEvent.WaitOne(1000); ?
  34. ????????????Console.WriteLine("Method?start?at?:?"?+?DateTime.Now.ToLongTimeString());?????? ?
  35. ????????} ?
  36. ????} ?
  37. }?
運行結果:

如果你把創建事件為手動重置事件ManualResetEvent時,得到的運行結果就會下面這樣:

2.3 跨進程之間同步

內核模式的構造可同步在同一臺機器上的不同進程中運行的線程,所以我們同樣可以使用 AutoResetEvent實現不同進程中運行的線程同步,但是此時需要對AutoResetEvent進行命名,但是AutoResetEvent只提供帶一個參數的構造函數的,此時應該如何去實現不同進程中的線程同步的呢?

其實是有解決辦法的,因為AutoResetEvent是繼承自EventWaitHandle類的,EventWaitHandle類有多個構造函數的

除了之前的方法創建AutoResetEvent對象外,

還可以通過EventWaitHandle AutoEvent = new EventWaitHandle (false, EventResetMode.Auto);這樣的方法來構造AutoResetEvent對象,通過

EventWaitHandle autoEvent = new EventWaitHandle (false, EventResetMode.Auto,"My");方式就可以指定名稱了

下面一段代碼演示如何實現跨不同進程中的線程同步:

 
  1. using?System; ?
  2. using?System.Threading; ?
  3. ?
  4. namespace?CrossProcess_EventWaitHandle ?
  5. { ?
  6. ????class?Program ?
  7. ????{ ?
  8. ????????public?static?EventWaitHandle?autoEvent?=?new?EventWaitHandle(true,?EventResetMode.AutoReset,?"My"); ?
  9. ????????static?void?Main(string[]?args) ?
  10. ????????{ ?
  11. ????????????Console.WriteLine("Main?Thread?Start?run?at:?"?+?DateTime.Now.ToLongTimeString()); ?
  12. ????????????Thread?t?=?new?Thread(TestMethod); ?
  13. ???????????? ?
  14. ????????????//?為了有時間啟動另外一個線程 ?
  15. ????????????Thread.Sleep(2000); ?
  16. ????????????t.Start(); ?
  17. ????????????Console.Read(); ?
  18. ????????} ?
  19. ?
  20. ????????public?static?void?TestMethod() ?
  21. ????????{ ?
  22. ????????????//?進程一:顯示的時間間隔為2秒 ?
  23. ????????????//?進程二中顯示的時間間隔為3秒 ?
  24. ????????????//?因為進程二中AutoResetEvent的初始狀態為非終止的 ?
  25. ????????????//?因為在進程一中通過WaitOne方法的調用已經把AutoResetEvent的初始狀態返回為非終止狀態了 ?
  26. ????????????autoEvent.WaitOne(1000); ?
  27. ????????????Console.WriteLine("Method?start?at?:?"+?DateTime.Now.ToLongTimeString()); ?
  28. ????????} ?
  29. ????} ?
  30. }?
運行結果:

?三、小結

???? 本來打算在一篇文章里面講述內核模式構造的,寫著寫著滾動條又變很小了,為了大家的閱讀,我把信號量和互斥體放在后面一篇文章里面講吧,相信后面的內容會很好理解的,因為后面兩個類的使用和這篇中講到的使用很類似,好歹都是繼承WaitHandle類的。





? ? ?本文轉自LearningHard 51CTO博客,原文鏈接:http://blog.51cto.com/learninghard/1034792,如需轉載請自行聯系原作者


本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/539972.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/539972.shtml
英文地址,請注明出處:http://en.pswp.cn/news/539972.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

java redis set list_RedisTemplate的各種操作(set、hash、list、string)_lichuangcsdn的博客-CSDN博客...

注入以下RedisTemplateAutowiredprivate RedisTemplate redisTemplate;1、保存和讀取Set:代碼示例:SetOperations set redisTemplate.opsForSet(); set.add("set1","22"); set.add("set1","33"); set.add(&quo…

閃屏頁面(Splash)開發

業余作品--365安全衛士 ------------------------------------------- 閃屏頁面(Splash):app剛啟動時的頁面 作用: 1、展示公司品牌logo 2、應用初始化。如游戲app第一次啟動初始化數據 3、檢測新版本。 4、檢測程序合法性。如 招商銀行app在啟動…

matlab2016b ubuntu命令行安裝 + matconvnet的安裝

0. 下載安裝包 下載的文件有Matlab 2016b Linux64 Crack.rar,R2016b_glnxa64_dvd2.iso,R2016b_glnxa64_dvd1.iso。 1. 拷貝安裝文件并上傳服務器 在Windows下用虛擬光驅打開,并將R2016b_glnxa64_dvd1.iso和R2016b_glnxa64_dvd2.iso所有內容復…

科普dip,dp,sp,dpi,ppi,px,Density

一、概念 DPI:DPI是Dots Per Inch的縮寫,也就是“每英寸點數”,打印機分辨率。這里所說的“點”,在屏幕上并不是不變的,并不是唯一對應屏幕上的像素點,而是受到分辨率等因素的影響。這個點有可能是1個像素…

do與mysql數據類型對照_dophon-db: dophon框架的數據庫模塊,支持mysql,sqlite數據庫,帶有orm持久化功能與鏈式操作實例,貼近邏輯習慣,支持mysql多數據源配置...

dophon-db項目介紹dophon框架的數據庫模塊,也可單獨作為一個與數據庫模塊交互的部件支持mysql數據庫連接支持orm形式的數據操作如有疑問請發送郵件聯系作者:ealohu163.com軟件架構模塊架構分為以組件:mysql連接組件(包括連接池,連接封裝類,分頁,結果輸出過濾器,遠程接收器,增量…

clamp 函數

返回范圍內的一個數值。可以使用 clamp 函數將不斷增加、減小或隨機變化的數值限制在一系列的值中。 float clamp(float minnumber, float maxnumber, float parameter) 最小數值和最大數值指定返回值的范圍。 參數是值要鉗制在范圍內的屬性或變量。 如果參數位于最小數值和最大…

jquery $.each遍歷json數組方法

轉載地址&#xff1a;http://blog.sina.com.cn/s/blog_636f2d150101ezs1.html <!doctype html public "-//w3c//dtd xhtml 1.0 transitional//en" "http://www.w3.org/tr/xhtml1/dtd/xhtml1-transitional.dtd"> <html xmlns"http://www.w3.o…

java 責任鏈模式 鏈表_責任鏈模式的實現及源碼中應用

01—責任鏈模式的實現假設一個出差任務的流程需要審批出差行程和出差報銷金額。那么&#xff0c;對應兩個部門的審核。我們先定義一個出差任務Task類&#xff1a;然后&#xff0c;我們定義一個抽象的處理類Handler&#xff0c;其中具體的處理方法Handle交給子類去實現。然后&am…

JQuery $.each遍歷JSON字符串報Uncaught TypeError:Cannot use 'in' operator to search for

查看一個簡單的jQuery的例子來遍歷一個JavaScript數組對象。 [js] view plaincopy var json [ {"id":"1","tagName":"apple"}, {"id":"2","tagName":"orange"}, {"id":&quo…

php setcookie 過期,php cookie怎么設置過期時間?

PHP中可以使用setcookie()函數設置cookie的過期時間。語法為“setcookie(name,value,expire,path,domain,secure)”&#xff1b;其中expire參數用于指定cookie的有效期&#xff0c;即過期時間戳。setcookie() 函數向客戶端發送一個 HTTP cookie。cookie 是由服務器發送到瀏覽器…

nginx自定義500、404錯誤頁面

1&#xff0c;首先在http添加以下內容 http{ fastcgi_intercept_errors on; } 2&#xff0c;server中添加以下內容&#xff1a; 注意路徑 error_page 500 502 503 504 /500.html; location /500.html { internal; } error_page 404 /404.html; location /404.html { intern…

php如何輸出復選框的值,php 怎么輸出復選框呢?

表單有6個復選框&#xff0c;如果選中的分別是第126個&#xff0c;數據庫存為 1&#xff0c;2&#xff0c;6現在的問題是 在修改的頁面 怎么用php從數據庫取值&#xff0c;輸出6個復選框&#xff0c;讓126為checked &#xff1f;回復討論(解決方案)$row[id]1;>我的意思是 從…

jQuery Mobile動態刷新頁面樣式

見 百度經驗 http://jingyan.baidu.com/article/7f766dafbc18f24101e1d014.html JQM里面當我們更新了某些頁面標簽(如: listview, radiobuttons, checkboxes, select menus)里的數據時,必須做refresh操作. 為什么必須做refresh操作操作呢?因為JQM在做頁面渲染的時候,為了使樣…

R-CNN論文翻譯

R-CNN論文翻譯Rich feature hierarchies for accurate object detection and semantic segmentation用于精確物體定位和語義分割的豐富特征層次結構2017-11-29摘要過去幾年&#xff0c;在權威數據集PASCAL上&#xff0c;物體檢測的效果已經達到一個穩定水平。效果最好的方法是融…

inflate簡介,LayoutInflater和inflate()方法的用法

一、inflate簡介 inflate這個方法總共有四種形式&#xff08;見下面&#xff09;&#xff0c;目的都是把xml表述的layout轉化為View對象。 其中有一個比較常用&#xff0c;View inflate(int resource, ViewGroup root)&#xff0c;另三個&#xff0c;其實目的和這個差不多。 …

php ci框架 實例化類,php框架CI(codeigniter)自動加載與自主創建對象操作實例分析...

本文實例講述了php框架CI(codeigniter)自動加載與自主創建對象操作。分享給大家供大家參考&#xff0c;具體如下&#xff1a;CI的autoload很好用&#xff0c;自動創建對象&#xff0c;但是注意&#xff0c;他的對象只有一個。我們很多情況下需要生成對象&#xff0c;這就很麻煩…

sass、gulp應用

Sass介紹n CSS 不是一個編程語言&#xff0c;可以用它來開發網頁樣式&#xff0c;但是沒有辦法用它進行編程。SASS 的出現&#xff0c;讓 CSS 實現了通過代碼編程來實現的方式。n SASS 是一種 CSS 開發工具&#xff0c;提供了許多便利的寫法&#xff0c;讓CSS 的處理實現了可編…

自定義控件SettingItemView

一、效果圖 選中&#xff1a;顯示自動更新開啟不選擇&#xff1a;顯示自動更新關閉------------在布局文件中的使用方式和android自生的控件一樣 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas.andro…

php中如何存儲多個文本框,php-如何將每個字符的文本框拆分為多個子文本框

我正在設計一個PHP表單,其中包含一些輸入字段,如下圖所示.如何將輸入類型(文本框)拆分為單個字符子文本框,或將文本框拆分為給定字符串的每個字符的多列文本框.以及如何在其中插入數據| JOHN DOE |進入| J | O | H | N | | D | O | E |這樣解決方法:的HTML的CSS#text{backgroun…

為什么會有 AOP

為什么80%的碼農都做不了架構師&#xff1f;>>> AOP 面向切面的編程。 先上三張圖片 三處對數據庫進行操作&#xff0c; 但這三處有大量的重復的代碼&#xff0c;每次都是獲取session&#xff0c;獲取mapper&#xff0c;執行&#xff0c; commit&#xff0c;close…