标准库

OpenHarmony内核使用musl libc库，支持标准POSIX接口，开发者可基于POSIX标准接口开发内核之上的组件及应用。

框架流程

图 1 POSIX接口框架
标准库 - 图1

musl libc库支持POSIX标准，涉及的系统调用相关接口由OpenHarmony内核适配支持 ，以满足接口对外描述的功能要求。

开发指导

标准库支持接口的详细情况请参考C库的API文档，其中也涵盖了与POSIX标准之间的差异说明。开发者可根据已经提供的接口，开发组件及应用等。

操作实例

在本示例中，主线程创建了THREAD_NUM个子线程，每个子线程启动后等待被主线程唤醒，主线程成功唤醒所有子线程后，子线程继续执行直至生命周期结束，同时主线程通过pthread_join方法等待所有线程执行结束。


1. #include <stdio.h>
2. #include <unistd.h>
3. #include <pthread.h>

5. #ifdef __cplusplus
6. #if __cplusplus
7. extern "C" {
8. #endif /* __cplusplus */
9. #endif /* __cplusplus */

11. #define THREAD_NUM 3
12. int g_startNum = 0; /* 启动的线程数 */
13. int g_wakenNum = 0; /* 唤醒的线程数 */

15. struct testdata {
16. pthread_mutex_t mutex;
17. pthread_cond_t cond;
18. } g_td;

20. /* *
21. * 子线程入口函数
22. */
23. static void *ChildThreadFunc(void *arg)
24. {
25. int rc;
26. pthread_t self = pthread_self();

28. /* 获取mutex锁 */
29. rc = pthread_mutex_lock(&g_td.mutex);
30. if (rc != 0) {
31. printf("ERROR:take mutex lock failed, error code is %d!\n", rc);
32. goto EXIT;
33. }

35. /* g_startNum计数加一，用于统计已经获得mutex锁的子线程个数 */
36. g_startNum++;

38. /* 等待cond条件变量 */
39. rc = pthread_cond_wait(&g_td.cond, &g_td.mutex);
40. if (rc != 0) {
41. printf("ERROR: pthread condition wait failed, error code is %d!\n", rc);
42. (void)pthread_mutex_unlock(&g_td.mutex);
43. goto EXIT;
44. }

46. /* 尝试获取mutex锁 */
47. rc = pthread_mutex_trylock(&g_td.mutex);
48. if (rc == 0) {
49. /* 失败则退出 */
50. printf("ERROR: mutex trylock failed, error code is %d!\n", rc);
51. goto EXIT;
52. }

54. /* g_wakenNum计数加一，用于统计已经被cond条件变量唤醒的子线程个数 */
55. g_wakenNum++;

57. /* 释放mutex锁 */
58. rc = pthread_mutex_unlock(&g_td.mutex);
59. if (rc != 0) {
60. printf("ERROR: mutex release failed, error code is %d!\n", rc);
61. goto EXIT;
62. }
63. EXIT:
64. return NULL;
65. }

67. static int testcase(void)
68. {
69. int i, rc;
70. pthread_t thread[THREAD_NUM];

72. /* 初始化mutex锁 */
73. rc = pthread_mutex_init(&g_td.mutex, NULL);
74. if (rc != 0) {
75. printf("ERROR: mutex init failed, error code is %d!\n", rc);
76. goto ERROROUT;
77. }

79. /* 初始化cond条件变量 */
80. rc = pthread_cond_init(&g_td.cond, NULL);
81. if (rc != 0) {
82. printf("ERROR: pthread condition init failed, error code is %d!\n", rc);
83. goto ERROROUT;
84. }

86. /* 批量创建THREAD_NUM个子线程 */
87. for (i = 0; i < THREAD_NUM; i++) {
88. rc = pthread_create(&thread[i], NULL, ChildThreadFunc, NULL);
89. if (rc != 0) {
90. printf("ERROR: pthread create failed, error code is %d!\n", rc);
91. goto ERROROUT;
92. }
93. }

95. /* 等待所有子线程都完成mutex锁的获取 */
96. while (g_startNum < THREAD_NUM) {
97. usleep(100);
98. }

100. /* 获取mutex锁，确保所有子线程都阻塞在pthread_cond_wait上 */
101. rc = pthread_mutex_lock(&g_td.mutex);
102. if (rc != 0) {
103. printf("ERROR: mutex lock failed, error code is %d\n", rc);
104. goto ERROROUT;
105. }

107. /* 释放mutex锁 */
108. rc = pthread_mutex_unlock(&g_td.mutex);
109. if (rc != 0) {
110. printf("ERROR: mutex unlock failed, error code is %d!\n", rc);
111. goto ERROROUT;
112. }

114. for (int j = 0; j < THREAD_NUM; j++) {
115. /* 在cond条件变量上广播信号 */
116. rc = pthread_cond_signal(&g_td.cond);
117. if (rc != 0) {
118. printf("ERROR: pthread condition failed, error code is %d!\n", rc);
119. goto ERROROUT;
120. }
121. }

123. sleep(1);

125. /* 检查是否所有子线程都已被唤醒 */
126. if (g_wakenNum != THREAD_NUM) {
127. printf("ERROR: not all threads awaken, only %d thread(s) awaken!\n", g_wakenNum);
128. goto ERROROUT;
129. }

131. /* join所有子线程，即等待其结束 */
132. for (i = 0; i < THREAD_NUM; i++) {
133. rc = pthread_join(thread[i], NULL);
134. if (rc != 0) {
135. printf("ERROR: pthread join failed, error code is %d!\n", rc);
136. goto ERROROUT;
137. }
138. }

140. /* 销毁cond条件变量 */
141. rc = pthread_cond_destroy(&g_td.cond);
142. if (rc != 0) {
143. printf("ERROR: pthread condition destroy failed, error code is %d!\n", rc);
144. goto ERROROUT;
145. }
146. return 0;
147. ERROROUT:
148. return -1;
149. }

151. /*
152. * 示例代码主函数
153. */
154. int main(int argc, char *argv[])
155. {
156. int rc;

158. /* 启动测试函数 */
159. rc = testcase();
160. if (rc != 0) {
161. printf("ERROR: testcase failed!\n");
162. }

164. return 0;
165. }
166. #ifdef __cplusplus
167. #if __cplusplus
168. }
169. #endif /* __cplusplus */
170. #endif /* __cplusplus */

常见问题

无。