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>
9. #include "pthread_mutex.h"
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)
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){
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、開鎖
56. sleep(1);
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){
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);
77. sleep(1);
79. }
80. /*arg是將指針帶進來，cmd則相反，或者設置 NULL*/
81. pthread_exit(cmd);
82. //pthread_exit(NULL);
83. }
85. int XxManageThreadInit()
86. {
87. pthread_t tManageThread;
88. pthread_t tManageThreadMutex;
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. }
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. }
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. }
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);
136. if(XxManageThreadInit()==-1){
137. exit(1);
138. }
140. while(count--){
141. DBG("[0] main running\n");
142. sleep(2);
143. }
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