C++多线程（八）

拼搏现实的明天。 2022-08-14 00:44 176阅读 0赞

多线程同步之Event（主要用来线程间的等待通知）  
   
一 Event  
     在所有的内核对象中，事件内核对象是个最基本的对象。它们包含一个使用计数（与所有内核对象一样），一个用于指明该事件是个自动重置的事件还是一个人工重置的事件的布尔值，另一个用于指明该事件处于已通知状态还是未通知状态的布尔值。

事件能够通知一个操作已经完成。有两种不同类型的事件对象。一种是人工重置的事件，另一种是自动重置的事件。当人工重置的事件得到通知时，等待该事件的所有线程均变为可调度线程。当一个自动重置的事件得到通知时，等待该事件的线程中只有一个线程变为可调度线程。

当一个线程执行初始化操作，然后通知另一个线程执行剩余的操作时，事件使用得最多。事件初始化为未通知状态，然后，当该线程完成它的初始化操作后，它就将事件设置为已通知状态。这时，一直在等待该事件的另一个线程发现该事件已经得到通知，因此它就变成可调度线程。  
  
         Microsoft为自动重置的事件定义了应该成功等待的副作用规则，即当线程成功地等待到该对象时，自动重置的事件就会自动重置到未通知状态。这就是自动重置的事件如何获得它们的名字的方法。通常没有必要为自动重置的事件调用ResetEvent函数，因为系统会自动对事件进行重置。但是，Microsoft没有为人工重置的事件定义成功等待的副作用，所以需要调用ResetEvent()。  
  
二 Event API

<table style="width:705px"> 
 <tbody> 
 <tr> 
 <th>Event function</th> 
 <th>Description</th> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms682396.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">CreateEvent</a></td> 
 <td>Creates or opens a named or unnamed event object.</td> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms682400.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">CreateEventEx</a></td> 
 <td>Creates or opens a named or unnamed event object and returns a handle to the object.</td> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms684305.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">OpenEvent</a></td> 
 <td>Opens an existing named event object.</td> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms684914.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">PulseEvent</a></td> 
 <td>Sets the specified event object to the signaled state and then resets it to the nonsignaled state after releasing the appropriate number of waiting threads.</td> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms685081.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">ResetEvent</a></td> 
 <td>Sets the specified event object to the nonsignaled state.</td> 
 </tr> 
 <tr> 
 <td><a href="http://msdn2.microsoft.com/en-us/library/ms686211.aspx" style="color:rgb(0,102,170); text-decoration:none" rel="nofollow">SetEvent</a></td> 
 <td>Sets the specified event object to the signaled state.</td> 
 </tr> 
 </tbody> 
</table>

三 代码实例  
  
1）使用手动的Event：当文件读入内存的时候，WordCount， SpellCheck，GrammarCheck可以同时进行，这里使用Event，当文件一读入内存就通知WordCount，SpellCheck和GrammarCheck线程开始执行。

![None.gif][]\#include <windows.h> 
![None.gif][]\#include <process.h> 
![None.gif][]\#include <stdio.h> 
![None.gif][] 
![None.gif][]// a global handle to event. 
![None.gif][]HANDLE g\_hEvent; 
![None.gif][] 
![None.gif][]void OpenFileAndReadContentsIntoMemory(); 
![None.gif][]unsigned \_\_stdcall WordCount(void \*pvParam); 
![None.gif][]unsigned \_\_stdcall SpellCheck(void \*pvParam); 
![None.gif][]unsigned \_\_stdcall GrammarCheck(void \*pvParam); 
![None.gif][] 
![None.gif][]int main()  
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Create the manual-reset, nonsignaled event. 
![InBlock.gif][]   g\_hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); 
![InBlock.gif][] 
![InBlock.gif][]   //Spawn 3 new threads. 
![InBlock.gif][]   HANDLE hThread\[3\]; 
![InBlock.gif][]   unsigned dwThreadID\[3\]; 
![InBlock.gif][]   hThread\[0\] = (HANDLE)\_beginthreadex(NULL, 0, WordCount, NULL, 0, &dwThreadID\[0\]); 
![InBlock.gif][]   hThread\[1\] = (HANDLE)\_beginthreadex(NULL, 0, SpellCheck, NULL, 0, &dwThreadID\[1\]); 
![InBlock.gif][]   hThread\[2\] = (HANDLE)\_beginthreadex(NULL, 0, GrammarCheck, NULL, 0, &dwThreadID\[2\]); 
![InBlock.gif][] 
![InBlock.gif][]   OpenFileAndReadContentsIntoMemory(); 
![InBlock.gif][] 
![InBlock.gif][]   //Allow all 3 threads to access the memory. 
![InBlock.gif][]   SetEvent(g\_hEvent);  
![InBlock.gif][] 
![InBlock.gif][]   printf("main thread exit\\n"); 
![InBlock.gif][]   return 1; 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]void OpenFileAndReadContentsIntoMemory() 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]  printf("Open File and Read contents into memory\\n"); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall WordCount(void \*pvParam)  
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("0:word count\\n"); 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall SpellCheck(void \*pvParam) 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("1:Spell check\\n"); 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall GrammarCheck(void \*pvParam) 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("2:Grammar check\\n"); 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\}

2）修改上面的代码，使用自动Event，则必须在3个子线程中增加SetEvent（）。且要想让3个线程都执行完，必须的增加Waitfor（）函数。

![None.gif][]\#include <windows.h> 
![None.gif][]\#include <process.h> 
![None.gif][]\#include <stdio.h> 
![None.gif][] 
![None.gif][]// a global handle to event. 
![None.gif][]HANDLE g\_hEvent; 
![None.gif][] 
![None.gif][]void OpenFileAndReadContentsIntoMemory(); 
![None.gif][]unsigned \_\_stdcall WordCount(void \*pvParam); 
![None.gif][]unsigned \_\_stdcall SpellCheck(void \*pvParam); 
![None.gif][]unsigned \_\_stdcall GrammarCheck(void \*pvParam); 
![None.gif][] 
![None.gif][]int main()  
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Create the AUTO-reset, nonsignaled event. 
![InBlock.gif][]   g\_hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); 
![InBlock.gif][] 
![InBlock.gif][]   //Spawn 3 new threads. 
![InBlock.gif][]   HANDLE hThread\[3\]; 
![InBlock.gif][]   unsigned dwThreadID\[3\]; 
![InBlock.gif][]   hThread\[0\] = (HANDLE)\_beginthreadex(NULL, 0, WordCount, NULL, 0, &dwThreadID\[0\]); 
![InBlock.gif][]   hThread\[1\] = (HANDLE)\_beginthreadex(NULL, 0, SpellCheck, NULL, 0, &dwThreadID\[1\]); 
![InBlock.gif][]   hThread\[2\] = (HANDLE)\_beginthreadex(NULL, 0, GrammarCheck, NULL, 0, &dwThreadID\[2\]); 
![InBlock.gif][] 
![InBlock.gif][]   OpenFileAndReadContentsIntoMemory(); 
![InBlock.gif][] 
![InBlock.gif][]   //Allow all 3 threads to access the memory. 
![InBlock.gif][]   SetEvent(g\_hEvent);  
![InBlock.gif][] 
![InBlock.gif][]    //wait for child threads to exit 
![InBlock.gif][]    DWORD dwCThd = WaitForMultipleObjects (3, //count of objects 
![InBlock.gif][]                                        hThread, //thread handle 
![InBlock.gif][]                                        TRUE, //wait for all 
![InBlock.gif][]                                        INFINITE); //time out interval 
![InBlock.gif][]    if(dwCThd != WAIT\_OBJECT\_0) 
![ExpandedSubBlockStart.gif][]    \{ 
![InBlock.gif][]        printf("error\\n"); 
![InBlock.gif][]        exit(-1); 
![ExpandedSubBlockEnd.gif][]    \} 
![InBlock.gif][] 
![InBlock.gif][]    //close handles 
![InBlock.gif][]    CloseHandle (g\_hEvent); 
![InBlock.gif][]    //close child thread handles 
![InBlock.gif][]    for (int i=0; i<3; i++) 
![InBlock.gif][]        CloseHandle (hThread\[i\]); 
![InBlock.gif][] 
![InBlock.gif][]   printf("main thread exit\\n"); 
![InBlock.gif][]   return 1; 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]void OpenFileAndReadContentsIntoMemory() 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]  printf("Open File and Read contents into memory\\n"); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall WordCount(void \*pvParam)  
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("0:word count\\n"); 
![InBlock.gif][]   SetEvent(g\_hEvent); 
![InBlock.gif][] 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall SpellCheck(void \*pvParam) 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("1:Spell check\\n"); 
![InBlock.gif][]   SetEvent(g\_hEvent); 
![InBlock.gif][] 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\} 
![None.gif][]unsigned \_\_stdcall GrammarCheck(void \*pvParam) 
![ExpandedBlockStart.gif][]\{ 
![InBlock.gif][]   //Wait until the file's data is in memory. 
![InBlock.gif][]   WaitForSingleObject(g\_hEvent, INFINITE); 
![InBlock.gif][] 
![InBlock.gif][]   //Access the memory block. 
![InBlock.gif][]   printf("2:Grammar check\\n"); 
![InBlock.gif][] 
![InBlock.gif][]   SetEvent(g\_hEvent); 
![InBlock.gif][] 
![InBlock.gif][]   return(0); 
![ExpandedBlockEnd.gif][]\}

四 参考   
windows核心编程

[None.gif]: /images/20220810/f24976f06a1b471ba56954db396cd7dd.png
[ExpandedBlockStart.gif]: /images/20220810/0f699e57702f4741a729ab7cf33e6ddc.png
[InBlock.gif]: /images/20220810/f61bd8693552458bb7c8e57a1a025a69.png
[ExpandedBlockEnd.gif]: /images/20220810/32a546795a714340bbfac5f89e80cf73.png
[ExpandedSubBlockStart.gif]: /images/20220810/3e44be41686e4c27b38a7059016092fb.png
[ExpandedSubBlockEnd.gif]: /images/20220810/c7a9afb2744a4ddbbe0985a9d9fd72ca.png