使用信号量进行线程同步

1. #include <windows.h> 
2. #include <stdio.h> 
3.  
4. #define NUMTHREADS 4 
5.  
6. HANDLE hSemaphore; 
7.  
8. void UseSemaphore(void); 
9. DWORD WINAPI SemaphoreThread(LPVOID lpParam); 
10.  
11. int main(void){ 
12.     UseSemaphore(); 
13. } 
14.  
15. void UseSemaphore(void){ 
16.     HANDLE hThread[NUMTHREADS]; 
17.     INT i; 
18.     LONG lMax; 
19.     CHAR cMax; 
20.     printf("将创建%d个线程,获得信号量的线程可以向屏幕打印.\n请输入信号量的最大计数1-%d:",NUMTHREADS,NUMTHREADS); 
21.     cMax = getch(); 
22.     printf("%c\n",cMax); 
23.     lMax = cMax & 0xF; 
24.     if(lMax<0 || lMax>NUMTHREADS){ 
25.         printf("请输入1-%d.\n",NUMTHREADS); 
26.     } 
27.     hSemaphore = CreateSemaphore(NULL,lMax,lMax,NULL); 
28.     if(hSemaphore == NULL){ 
29.         printf("Create Semaphorec error.(%d)\n",GetLastError()); 
30.     } 
31.     for(i=0;i<NUMTHREADS;i++){ 
32.         hThread[i] = CreateThread(NULL,0,SemaphoreThread,&i,0,NULL); 
33.         if(hThread[i] == NULL){ 
34.             printf("Create Threads error.(%d)\n",GetLastError()); 
35.             return; 
36.         } 
37.     } 
38.     WaitForMultipleObjects(NUMTHREADS,hThread,TRUE,INFINITE); 
39. } 
40.  
41. DWORD WINAPI SemaphoreThread(LPVOID lpParam){ 
42.     DWORD dwWaitResult; 
43.     BYTE lpRead[16]; 
44.     DWORD j = 0; 
45.     DWORD dwPreviousCount; 
46.  
47.     for(;j<3;j++){ 
48.         Sleep(rand()%1000); 
49.         dwWaitResult = WaitForSingleObject(hSemaphore,INFINITE); 
50.         switch(dwWaitResult){ 
51.         case WAIT_OBJECT_0: 
52.             printf("\nProcess %d Gets Semaphore",GetCurrentThreadId()); 
53.             break; 
54.         default: 
55.             printf("\nprocess %u wait error:%u",GetCurrentThreadId(),GetLastError()); 
56.         } 
57.         Sleep(rand()%1000); 
58.         if(!ReleaseSemaphore(hSemaphore,1,&dwPreviousCount)) 
59.         { 
60.             printf("\nprocess %u Release Semaphore error:%d",GetCurrentProcessId(),GetLastError()); 
61.         }else 
62.         { 
63.             printf("\nProcess %u Release Semaphore,previous count is %u",GetCurrentProcessId(),dwPreviousCount); 
64.         } 
65.     } 
66.     return 1; 
67. } 

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