Linux基礎編程 多線程同步 pthread_cond_signal

條件變量同步鎖示例

此例根據上一篇文章修改 （見 http://www.linuxidc.com/Linux/2012-07/65030.htm ）

請包含上一篇中的兩個文件（未做任何改動）

1/ pthread_mutex.h

2/ pthread_mutex.c

上一篇的thread.c文件修改如下

1. /* 
2. 多線程同步示例，條件變量同步鎖 
3. */  
4. #include <stdio.h>   
5. #include <stdlib.h>   
6. #include <unistd.h>   
7. #include <pthread.h>   
8.   
9. #include "pthread_mutex.h"   
10.   
11. #define __DEBUG   
12. #ifdef __DEBUG   
13. #define DBG(fmt,args...) fprintf(stdout,  fmt,  ##args)   
14. #else   
15. #define DBG(fmt,args...)   
16. #endif   
17. #define ERR(fmt,args...) fprintf(stderr,  fmt,  ##args)   
18.   
19. static int isThreadQuit = 0;  
20. SemHandl_t gHndlSem = NULL;  
21. /*條件變量同步鎖*/  
22. pthread_cond_t gNoneZero;  
23. unsigned int gCount = 0;//條件變量   
24. /* 
25. 某設備寫操作，不同同時訪問，所以所以需要線程鎖保護 
26. 1、將函數DeviceWrite中加鎖 
27. 2、在訪問DeviceWrite的線程中加鎖 
28. 以上兩種方法跟據需要選擇其一。 
29. 本例中在訪問的線程中加鎖 
30. */  
31. void DeviceWrite(char *str)  
32. {  
33.     /*SemWait(gHndlSem);*/  
34.     DBG("Device Write: %s\n",str);  
35.     /*SemRelease(gHndlSem);*/  
36. }  
37. void SetXxThreadQuit()  
38. {     
39.     /*quit*/  
40.     isThreadQuit = 1;  
41. }  
42. void *XxManageThread(void *arg)  
43. {  
44.     char *cmd = (char*)arg;  
45.     DBG("arg value=%s\n",cmd);  
46.     while(isThreadQuit==0){  
47.           
48.         SemWait(gHndlSem);// 1、先鎖定   
49.         while(gCount==0){// 2、判斷條件變量   
50.             pthread_cond_wait(&gNoneZero,gHndlSem);// 3、如果滿足，等待   
51.         }  
52.         gCount = gCount-1;// 4、條件變量做相應調整   
53.         DBG("gCount=%d\n",gCount);  
54.         SemRelease(gHndlSem); // 5、開鎖   
55.   
56.         sleep(1);  
57.           
58.     }  
59.     /*arg是將指針帶進來，cmd則相反，或者設置 NULL*/  
60.     pthread_exit(cmd);  
61.     //pthread_exit(NULL);   
62. }  
63. void *XxManageThreadMutex(void *arg)  
64. {  
65.     char *cmd = (char*)arg;  
66.     DBG("arg value=%s\n",cmd);  
67.     while(isThreadQuit==0){  
68.           
69.         SemWait(gHndlSem);  
70.         if(gCount == 0){  
71.             pthread_cond_signal(&gNoneZero);  
72.         }  
73.         gCount = gCount+1;  
74.         DBG("gCount=%d\n",gCount);  
75.         SemRelease(gHndlSem);  
76.           
77.         sleep(1);  
78.           
79.     }  
80.     /*arg是將指針帶進來，cmd則相反，或者設置 NULL*/  
81.     pthread_exit(cmd);  
82.     //pthread_exit(NULL);   
83. }  
84.   
85. int XxManageThreadInit()  
86. {  
87.     pthread_t tManageThread;  
88.     pthread_t tManageThreadMutex;  
89.       
90.     char *any="any value";  
91.     char *retn;  
92.     int ret;  
93.     /* 
94.       第二個參數是設置線程屬性，一般很少用到(設置優先級等)，第四個參數為傳遞到線程的指針， 
95.       可以為任何類型 
96.     */  
97.     ret = pthread_create(&tManageThread,NULL,XxManageThread,"1 thread");  
98.     if(ret == -1){  
99.         /*成功返回0.失敗返回-1*/  
100.         ERR("Ctreate Thread ERROR\n");  
101.         return -1;  
102.     }  
103.   
104.     ret = pthread_create(&tManageThreadMutex,NULL,XxManageThreadMutex,"2 thread");  
105.     if(ret == -1){  
106.         /*成功返回0.失敗返回-1*/  
107.         ERR("Ctreate Thread ERROR\n");  
108.         return -1;  
109.     }  
110.       
111.     /* 
112.       設置線程退出時資源的清理方式，如果是detach，退出時會自動清理 
113.       如果是join，則要等待pthread_join調用時才會清理 
114.     */  
115.     pthread_detach(tManageThread);  
116.     pthread_detach(tManageThreadMutex);  
117.     //pthread_join(tManageThread,retn);   
118.     //DBG("retn value=%s\n",retn);   
119.     return 0;  
120. }  
121.   
122. #define TEST_MAIN   
123. #ifdef TEST_MAIN   
124. int main()  
125. {  
126.     printf("hello liuyu\n");  
127.     int count=3;  
128.     /*創建線程鎖*/  
129.     gHndlSem = MakeSem();  
130.     if(gHndlSem == NULL){  
131.         return -1;  
132.     }  
133.     /*條件變量同步鎖初始化*/  
134.     pthread_cond_init(&gNoneZero,NULL);  
135.       
136.     if(XxManageThreadInit()==-1){  
137.         exit(1);  
138.     }  
139.       
140.     while(count--){  
141.         DBG("[0] main running\n");  
142.         sleep(2);  
143.     }  
144.       
145.     SetXxThreadQuit();  
146.     /*等待線程結束*/  
147.     sleep(1);  
148.     /*刪除條件變量同步鎖*/  
149.     pthread_cond_destroy(&gNoneZero);  
150.     /*刪除線程鎖*/  
151.     DestroySem(gHndlSem);  
152.     DBG("waitting thread exit...\n");  
153.     return 0;  
154. }  
155. #endif