多个线程互同步问题

1. #include <windows.h> 
2. #include <stdio.h> 
3.  
4. #define NUMTHREADS 3 
5. #define BUFFER_SIZE 16 
6. #define FOR_TIMES 5 
7.  
8. HANDLE hWriteEvents[NUMTHREADS]; 
9. HANDLE hReadEvents[NUMTHREADS]; 
10. BYTE lpSharedBuffer[16]={0}; 
11.  
12. void MultiEvents(void); 
13. VOID WriteToBuffer(VOID); 
14.  
15. DWORD WINAPI ThreadFunction(LPVOID lpParam); 
16.  
17. int main(){ 
18.     MultiEvents(); 
19. } 
20.  
21. void MultiEvents(void){ 
22.     HANDLE hThread; 
23.     DWORD i; 
24.     for(i=0;i<NUMTHREADS;i++){ 
25.         hWriteEvents[i] = CreateEvent(NULL,FALSE,FALSE,NULL); 
26.         if(hWriteEvents[i]==NULL){ 
27.             printf("CreateEvent failed.(%d)\n",GetLastError()); 
28.             return; 
29.         } 
30.         hReadEvents[i] = CreateEvent(NULL,FALSE,FALSE,NULL); 
31.         if(hReadEvents[i]==NULL){ 
32.             printf("CreateEvent failed.(%d)\n",GetLastError()); 
33.             return; 
34.         } 
35.         hThread = CreateThread(NULL,0,ThreadFunction,i,0,NULL); 
36.         if(hThread == NULL){ 
37.             printf("CreateThread failed.(%d)\n",GetLastError()); 
38.             return; 
39.         } 
40.     } 
41.     WriteToBuffer(); 
42. } 
43.  
44. VOID WriteToBuffer(VOID){ 
45.     DWORD dwWaitResult,i,j; 
46.     for(j=0;j<FOR_TIMES;j++){ 
47.         Sleep(rand()%100); 
48.         wsprintf(lpSharedBuffer,"shared %d",j); 
49.         for(i=0;i<NUMTHREADS;i++){ 
50.             if(!SetEvent(hWriteEvents[i])){ 
51.                 printf("SetEvent failed.(%d)\n",GetLastError()); 
52.                 return; 
53.             } 
54.         } 
55.         dwWaitResult = WaitForMultipleObjects(NUMTHREADS,hReadEvents,TRUE,INFINITE); 
56.         if(dwWaitResult != WAIT_OBJECT_0){ 
57.             printf("Wait error.(%d)\n",GetLastError()); 
58.             ExitProcess(0); 
59.         } 
60.     } 
61. } 
62.  
63. DWORD WINAPI ThreadFunction(LPVOID lpParam){ 
64.     DWORD dwWaitResult; 
65.     BYTE lpRead[16]; 
66.     DWORD j = 0; 
67.     DWORD dwThreadIndex = (DWORD)lpParam; 
68.     for(j=0;j<FOR_TIMES;j++){ 
69.         dwWaitResult = WaitForSingleObject(hWriteEvents[dwThreadIndex],INFINITE); 
70.         switch (dwWaitResult){ 
71.         case WAIT_OBJECT_0: 
72.             Sleep(rand()%10); 
73.             CopyMemory(lpRead,lpSharedBuffer,16); 
74.             break; 
75.         default: 
76.             printf("Wait error:%d\n",GetLastError()); 
77.             return 0; 
78.         } 
79.         printf("线程%u\t第%d次读,内容:%s\n",dwThreadIndex,j,(LPSTR)lpRead); 
80.     } 
81.     return 1; 
82. } 

本文转hackfreer51CTO博客，原文链接：http://blog.51cto.com/pnig0s1992/671381，如需转载请自行联系原作者