标准库

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>
  4. #ifdef __cplusplus
  5. #if __cplusplus
  6. extern"C"{
  7. #endif/* __cplusplus */
  8. #endif/* __cplusplus */
  9. #define THREAD_NUM 3
  10. int g_startNum =0;/* 启动的线程数 */
  11. int g_wakenNum =0;/* 唤醒的线程数 */
  12. struct testdata {
  13. pthread_mutex_t mutex;
  14. pthread_cond_t cond;
  15. } g_td;
  16. /* *
  17. * 子线程入口函数
  18. */
  19. staticvoid*ChildThreadFunc(void*arg)
  20. {
  21. int rc;
  22. pthread_tself= pthread_self();
  23. /* 获取mutex锁 */
  24. rc = pthread_mutex_lock(&g_td.mutex);
  25. if(rc !=0){
  26. printf("ERROR:take mutex lock failed, error code is %d!\n", rc);
  27. goto EXIT;
  28. }
  29. /* g_startNum计数加一,用于统计已经获得mutex锁的子线程个数 */
  30. g_startNum++;
  31. /* 等待cond条件变量 */
  32. rc = pthread_cond_wait(&g_td.cond,&g_td.mutex);
  33. if(rc !=0){
  34. printf("ERROR: pthread condition wait failed, error code is %d!\n", rc);
  35. (void)pthread_mutex_unlock(&g_td.mutex);
  36. goto EXIT;
  37. }
  38. /* 尝试获取mutex锁 */
  39. rc = pthread_mutex_trylock(&g_td.mutex);
  40. if(rc ==0){
  41. /* 失败则退出 */
  42. printf("ERROR: mutex trylock failed, error code is %d!\n", rc);
  43. goto EXIT;
  44. }
  45. /* g_wakenNum计数加一,用于统计已经被cond条件变量唤醒的子线程个数 */
  46. g_wakenNum++;
  47. /* 释放mutex锁 */
  48. rc = pthread_mutex_unlock(&g_td.mutex);
  49. if(rc !=0){
  50. printf("ERROR: mutex release failed, error code is %d!\n", rc);
  51. goto EXIT;
  52. }
  53. EXIT:
  54. return NULL;
  55. }
  56. staticint testcase(void)
  57. {
  58. int i, rc;
  59. pthread_t thread[THREAD_NUM];
  60. /* 初始化mutex锁 */
  61. rc = pthread_mutex_init(&g_td.mutex, NULL);
  62. if(rc !=0){
  63. printf("ERROR: mutex init failed, error code is %d!\n", rc);
  64. goto ERROROUT;
  65. }
  66. /* 初始化cond条件变量 */
  67. rc = pthread_cond_init(&g_td.cond, NULL);
  68. if(rc !=0){
  69. printf("ERROR: pthread condition init failed, error code is %d!\n", rc);
  70. goto ERROROUT;
  71. }
  72. /* 批量创建THREAD_NUM个子线程 */
  73. for(i =0; i < THREAD_NUM; i++){
  74. rc = pthread_create(&thread[i], NULL,ChildThreadFunc, NULL);
  75. if(rc !=0){
  76. printf("ERROR: pthread create failed, error code is %d!\n", rc);
  77. goto ERROROUT;
  78. }
  79. }
  80. /* 等待所有子线程都完成mutex锁的获取 */
  81. while(g_startNum < THREAD_NUM){
  82. usleep(100);
  83. }
  84. /* 获取mutex锁,确保所有子线程都阻塞在pthread_cond_wait上 */
  85. rc = pthread_mutex_lock(&g_td.mutex);
  86. if(rc !=0){
  87. printf("ERROR: mutex lock failed, error code is %d\n", rc);
  88. goto ERROROUT;
  89. }
  90. /* 释放mutex锁 */
  91. rc = pthread_mutex_unlock(&g_td.mutex);
  92. if(rc !=0){
  93. printf("ERROR: mutex unlock failed, error code is %d!\n", rc);
  94. goto ERROROUT;
  95. }
  96. for(int j =0; j < THREAD_NUM; j++){
  97. /* 在cond条件变量上广播信号 */
  98. rc = pthread_cond_signal(&g_td.cond);
  99. if(rc !=0){
  100. printf("ERROR: pthread condition failed, error code is %d!\n", rc);
  101. goto ERROROUT;
  102. }
  103. }
  104. sleep(1);
  105. /* 检查是否所有子线程都已被唤醒 */
  106. if(g_wakenNum != THREAD_NUM){
  107. printf("ERROR: not all threads awaken, only %d thread(s) awaken!\n", g_wakenNum);
  108. goto ERROROUT;
  109. }
  110. /* join所有子线程,即等待其结束 */
  111. for(i =0; i < THREAD_NUM; i++){
  112. rc = pthread_join(thread[i], NULL);
  113. if(rc !=0){
  114. printf("ERROR: pthread join failed, error code is %d!\n", rc);
  115. goto ERROROUT;
  116. }
  117. }
  118. /* 销毁cond条件变量 */
  119. rc = pthread_cond_destroy(&g_td.cond);
  120. if(rc !=0){
  121. printf("ERROR: pthread condition destroy failed, error code is %d!\n", rc);
  122. goto ERROROUT;
  123. }
  124. return0;
  125. ERROROUT:
  126. return-1;
  127. }
  128. /*
  129. * 示例代码主函数
  130. */
  131. int main(int argc,char*argv[])
  132. {
  133. int rc;
  134. /* 启动测试函数 */
  135. rc = testcase();
  136. if(rc !=0){
  137. printf("ERROR: testcase failed!\n");
  138. }
  139. return0;
  140. }
  141. #ifdef __cplusplus
  142. #if __cplusplus
  143. }
  144. #endif/* __cplusplus */
  145. #endif/* __cplusplus */

常见问题

无。