C++多執行緒（八）

f66666602

1. 
   
2. 一 Event
   
3.      在所有的內核對像中，事件內核對象是個最基本的對象。它們包含一個使用計數（與所有內核對像一樣），一個用於指明該事件是個自動重置的事件還是一個人工重置的事件的布爾值，另一個用於指明該事件處於已通知狀態還是未通知狀態的布爾值。
   
4.         事件能夠通知一個操作已經完成。有兩種不同類型的事件對象。一種是人工重置的事件，另一種是自動重置的事件。當人工重置的事件得到通知時，等待該事件的所有執行緒均變為可調度執行緒。當一個自動重置的事件得到通知時，等待該事件的執行緒中只有一個執行緒變為可調度執行緒。
   
5.        當一個執行緒執行初始化操作，然後通知另一個執行緒執行剩餘的操作時，事件使用得最多。事件初始化為未通知狀態，然後，當該執行緒完成它的初始化操作後，它就將事件設置為已通知狀態。這時，一直在等待該事件的另一個執行緒發現該事件已經得到通知，因此它就變成可調度執行緒。
   
6. 
   
7.          Microsoft為自動重置的事件定義了應該成功等待的副作用規則，即當執行緒成功地等待到該對像時，自動重置的事件就會自動重置到未通知狀態。這就是自動重置的事件如何獲得它們的名字的方法。通常沒有必要為自動重置的事件調用ResetEvent函數，因為系統會自動對事件進行重置。但是，Microsoft沒有為人工重置的事件定義成功等待的副作用，所以需要調用ResetEvent()。
   
8. 
   
9. 二 Event API
   
10. 
    
11. [tr]            Event function            Description        [/tr]         CreateEvent Creates or opens a named or unnamed event object.
    
12.          CreateEventEx Creates or opens a named or unnamed event object and returns a handle to the object.
    
13.          OpenEvent Opens an existing named event object.
    
14.          PulseEvent Setsthe specified event object to the signaled state and then resets it tothe nonsignaled state after releasing the appropriate number of waitingthreads.
    
15.          ResetEvent Sets the specified event object to the nonsignaled state.
    
16.          SetEvent Sets the specified event object to the signaled state.
    
17. 
    
18. 
    
19. 三 代碼實例
    
20. 
    
21. 1）使用手動的Event：當檔案讀入記憶體的時候，WordCount， SpellCheck，GrammarCheck可以同時進行，這裡使用Event，當檔案一讀入記憶體就通知WordCount，SpellCheck和GrammarCheck執行緒開始執行。
    
22. #include <windows.h>
    
23. #include <process.h>
    
24. #include <stdio.h>
    
25. 
    
26. // a global handle to event.
    
27. HANDLE g_hEvent;
    
28. 
    
29. void OpenFileAndReadContentsIntoMemory();
    
30. unsigned __stdcall WordCount(void
    
31. *pvParam);
    
32. unsigned __stdcall SpellCheck(void
    
33. *pvParam);
    
34. unsigned __stdcall GrammarCheck(void
    
35. *pvParam);
    
36. 
    
37. int main()
    
38. {
    
39.    //Create the manual-reset、nonsignaled event.
    
40.    g_hEvent = CreateEvent(NULL、TRUE、FALSE、NULL);
    
41. 
    
42.    //Spawn 3 new threads.
    
43.    HANDLE hThread[3];
    
44.    unsigned dwThreadID[3];
    
45.    hThread[0] = (HANDLE)_beginthreadex(NULL、0、WordCount、NULL、0、&dwThreadID[0]);
    
46.    hThread[1] = (HANDLE)_beginthreadex(NULL、0、SpellCheck、NULL、0、&dwThreadID[1]);
    
47.    hThread[2] = (HANDLE)_beginthreadex(NULL、0、GrammarCheck、NULL、0、&dwThreadID[2]);
    
48. 
    
49.    OpenFileAndReadContentsIntoMemory();
    
50. 
    
51.    //Allow all 3 threads to access the memory.
    
52.    SetEvent(g_hEvent);
    
53. 
    
54.    printf("main thread exit\n");
    
55.    return
    
56. 1;
    
57. }
    
58. void OpenFileAndReadContentsIntoMemory()
    
59. {
    
60.   printf("Open File and Read contents into memory\n");
    
61. }
    
62. unsigned __stdcall WordCount(void
    
63. *pvParam)
    
64. {
    
65.    //Wait until the file's data is in memory.
    
66.    WaitForSingleObject(g_hEvent、INFINITE);
    
67. 
    
68.    //Access the memory block.
    
69.    printf("0:word count\n");
    
70.    return(0);
    
71. }
    
72. unsigned __stdcall SpellCheck(void
    
73. *pvParam)
    
74. {
    
75.    //Wait until the file's data is in memory.
    
76.    WaitForSingleObject(g_hEvent、INFINITE);
    
77. 
    
78.    //Access the memory block.
    
79.    printf("1:Spell check\n");
    
80.    return(0);
    
81. }
    
82. unsigned __stdcall GrammarCheck(void
    
83. *pvParam)
    
84. {
    
85.    //Wait until the file's data is in memory.
    
86.    WaitForSingleObject(g_hEvent、INFINITE);
    
87. 
    
88.    //Access the memory block.
    
89.    printf("2:Grammar check\n");
    
90.    return(0);
    
91. }
    
92. 
    
93. 2）修改上面的代碼，使用自動Event，則必須在3個子執行緒中增加SetEvent（）。且要想讓3個執行緒都執行完，必須的增加Waitfor（）函數。
    
94. 
    
95. #include <windows.h>
    
96. #include <process.h>
    
97. #include <stdio.h>
    
98. 
    
99. // a global handle to event.
    
100. HANDLE g_hEvent;
     
101. 
     
102. void OpenFileAndReadContentsIntoMemory();
     
103. unsigned __stdcall WordCount(void
     
104. *pvParam);
     
105. unsigned __stdcall SpellCheck(void
     
106. *pvParam);
     
107. unsigned __stdcall GrammarCheck(void
     
108. *pvParam);
     
109. 
     
110. int main()
     
111. {
     
112.    //Create the AUTO-reset、nonsignaled event.
     
113.    g_hEvent = CreateEvent(NULL、FALSE、FALSE、NULL);
     
114. 
     
115.    //Spawn 3 new threads.
     
116.    HANDLE hThread[3];
     
117.    unsigned dwThreadID[3];
     
118.    hThread[0] = (HANDLE)_beginthreadex(NULL、0、WordCount、NULL、0、&dwThreadID[0]);
     
119.    hThread[1] = (HANDLE)_beginthreadex(NULL、0、SpellCheck、NULL、0、&dwThreadID[1]);
     
120.    hThread[2] = (HANDLE)_beginthreadex(NULL、0、GrammarCheck、NULL、0、&dwThreadID[2]);
     
121. 
     
122.    OpenFileAndReadContentsIntoMemory();
     
123. 
     
124.    //Allow all 3 threads to access the memory.
     
125.    SetEvent(g_hEvent);
     
126. 
     
127.     //wait for child threads to exit
     
128.     DWORD dwCThd = WaitForMultipleObjects (3、//count of objects
     
129.                                         hThread、//thread handle
     
130.                                         TRUE、//wait for all
     
131.                                         INFINITE); //time out interval
     
132. 
     
133. if(dwCThd != WAIT_OBJECT_0)
     
134.     {
     
135.         printf("error\n");
     
136.         exit(-1);
     
137.     }
     
138. 
     
139.     //close handles
     
140.     CloseHandle (g_hEvent);
     
141.     //close child thread handles
     
142. 
     
143. for (int i=0; i<3; i++)
     
144.         CloseHandle (hThread);
     
145. 
     
146.    printf("main thread exit\n");
     
147.    return
     
148. 1;
     
149. }
     
150. void OpenFileAndReadContentsIntoMemory()
     
151. {
     
152.   printf("Open File and Read contents into memory\n");
     
153. }
     
154. unsigned __stdcall WordCount(void
     
155. *pvParam)
     
156. {
     
157.    //Wait until the file's data is in memory.
     
158.    WaitForSingleObject(g_hEvent、INFINITE);
     
159. 
     
160.    //Access the memory block.
     
161.    printf("0:word count\n");
     
162.    SetEvent(g_hEvent);
     
163. 
     
164.    return(0);
     
165. }
     
166. unsigned __stdcall SpellCheck(void
     
167. *pvParam)
     
168. {
     
169.    //Wait until the file's data is in memory.
     
170.    WaitForSingleObject(g_hEvent、INFINITE);
     
171. 
     
172.    //Access the memory block.
     
173.    printf("1:Spell check\n");
     
174.    SetEvent(g_hEvent);
     
175. 
     
176.    return(0);
     
177. }
     
178. unsigned __stdcall GrammarCheck(void
     
179. *pvParam)
     
180. {
     
181.    //Wait until the file's data is in memory.
     
182.    WaitForSingleObject(g_hEvent、INFINITE);
     
183. 
     
184.    //Access the memory block.
     
185.    printf("2:Grammar check\n");
     
186. 
     
187.    SetEvent(g_hEvent);
     
188. 
     
189.    return(0);
     
190. }
     
191. 
     
192. 四 參考
     
193. windows核心編程
     
194. 
     

複製代碼