1# 信号量 2 3 4## 基本概念 5 6信号量（Semaphore）是一种实现任务间通信的机制，可以实现任务间同步或共享资源的互斥访问。 7 8一个信号量的数据结构中，通常有一个计数值，用于对有效资源数的计数，表示剩下的可被使用的共享资源数，其值的含义分两种情况： 9 10- 0，表示该信号量当前不可获取，因此可能存在正在等待该信号量的任务。 11 12- 正值，表示该信号量当前可被获取。 13 14以同步为目的的信号量和以互斥为目的的信号量在使用上有如下不同： 15 16- 用作互斥时，初始信号量计数值不为0，表示可用的共享资源个数。在需要使用共享资源前，先获取信号量，然后使用一个共享资源，使用完毕后释放信号量。这样在共享资源被取完，即信号量计数减至0时，其他需要获取信号量的任务将被阻塞，从而保证了共享资源的互斥访问。另外，当共享资源数为1时，建议使用二值信号量，一种类似于互斥锁的机制。 17 18- 用作同步时，初始信号量计数值为0。任务1因获取不到信号量而阻塞，直到任务2或者某中断释放信号量，任务1才得以进入Ready或Running态，从而达到了任务间的同步。 19 20 21## 运行机制 22 23**信号量控制块** 24 25 26``` 27/** 28 * 信号量控制块数据结构 29 */ 30typedef struct { 31 UINT16 semStat; /* 信号量状态 */ 32 UINT16 semType; /* 信号量类型 */ 33 UINT16 semCount; /* 信号量计数 */ 34 UINT16 semId; /* 信号量索引号 */ 35 LOS_DL_LIST semList; /* 用于插入阻塞于信号量的任务 */ 36} LosSemCB; 37``` 38 39**信号量运作原理** 40 41信号量允许多个任务在同一时刻访问共享资源，但会限制同一时刻访问此资源的最大任务数目。当访问资源的任务数达到该资源允许的最大数量时，会阻塞其他试图获取该资源的任务，直到有任务释放该信号量。 42 43- 信号量初始化 44 初始化时为配置的N个信号量申请内存（N值可以由用户自行配置，通过LOSCFG_BASE_IPC_SEM_LIMIT宏实现），并把所有信号量初始化成未使用，加入到未使用链表中供系统使用 45 46- 信号量创建 47 从未使用的信号量链表中获取一个信号量，并设定初值。 48 49- 信号量申请 50 若其计数器值大于0，则直接减1返回成功。否则任务阻塞，等待其它任务释放该信号量，等待的超时时间可设定。当任务被一个信号量阻塞时，将该任务挂到信号量等待任务队列的队尾。 51 52- 信号量释放 53 若没有任务等待该信号量，则直接将计数器加1返回。否则唤醒该信号量等待任务队列上的第一个任务。 54 55- 信号量删除 56 将正在使用的信号量置为未使用信号量，并挂回到未使用链表。 57 58运行示意图如下图所示: 59 60 **图1** 小型系统信号量运作示意图 61  62 63 64## 开发指导 65 66 67### 接口说明 68 69 **表1** 创建/删除信号量 70 71| 接口**名称** | 描述 | 72| -------- | -------- | 73| LOS_SemCreate | 创建信号量，返回信号量ID | 74| LOS_BinarySemCreate | 创建二值信号量，其计数值最大为1 | 75| LOS_SemDelete | 删除指定的信号量 | 76 77 **表2** 申请/释放信号量 78 79| 接口**名称** | 描述 | 80| -------- | -------- | 81| LOS_SemPend | 申请指定的信号量，并设置超时时间 | 82| LOS_SemPost | 释放指定的信号量 | 83 84 85### 开发流程 86 871. 创建信号量LOS_SemCreate，若要创建二值信号量则调用LOS_BinarySemCreate。 88 892. 申请信号量LOS_SemPend。 90 913. 释放信号量LOS_SemPost。 92 934. 删除信号量LOS_SemDelete。 94 95>  **说明：** 96> 由于中断不能被阻塞，因此不能在中断中使用阻塞模式申请信号量。 97 98 99### 编程实例 100 101 102### 实例描述 103 104本实例实现如下功能： 105 1061. 测试任务ExampleSem创建一个信号量，锁任务调度，创建两个任务ExampleSemTask1、ExampleSemTask2, ExampleSemTask2优先级高于ExampleSemTask1，两个任务中申请同一信号量，解锁任务调度后两任务阻塞，测试任务ExampleSem释放信号量。 107 1082. ExampleSemTask2得到信号量，被调度，然后任务休眠20Ticks，ExampleSemTask2延迟，ExampleSemTask1被唤醒。 109 1103. ExampleSemTask1定时阻塞模式申请信号量，等待时间为10Ticks，因信号量仍被ExampleSemTask2持有，ExampleSemTask1挂起，10Ticks后仍未得到信号量，ExampleSemTask1被唤醒，试图以永久阻塞模式申请信号量，ExampleSemTask1挂起。 111 1124. 20Tick后ExampleSemTask2唤醒， 释放信号量后，ExampleSemTask1得到信号量被调度运行，最后释放信号量。 113 1145. ExampleSemTask1执行完，400Ticks后任务ExampleSem被唤醒，执行删除信号量。 115 116 117### 编程示例 118 119本演示代码在./kernel/liteos_a/testsuites/kernel/src/osTest.c中编译验证，在TestTaskEntry中调用验证入口函数ExampleSem。 120 121示例代码如下： 122 123``` 124#include "los_sem.h" 125#include "securec.h" 126 127/* 任务ID */ 128static UINT32 g_testTaskId01; 129static UINT32 g_testTaskId02; 130 131/* 测试任务优先级 */ 132#define TASK_PRIO_LOW 5 133#define TASK_PRIO_HI 4 134 135/* 信号量结构体id */ 136static UINT32 g_semId; 137 138VOID ExampleSemTask1(VOID) 139{ 140 UINT32 ret; 141 142 dprintf("ExampleSemTask1 try get sem g_semId, timeout 10 ticks.\n"); 143 144 /* 定时阻塞模式申请信号量，定时时间为10ticks */ 145 ret = LOS_SemPend(g_semId, 10); 146 /* 申请到信号量 */ 147 if (ret == LOS_OK) { 148 LOS_SemPost(g_semId); 149 return; 150 } 151 /* 定时时间到，未申请到信号量 */ 152 if (ret == LOS_ERRNO_SEM_TIMEOUT) { 153 dprintf("ExampleSemTask1 timeout and try get sem g_semId wait forever.\n"); 154 155 /*永久阻塞模式申请信号量*/ 156 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER); 157 dprintf("ExampleSemTask1 wait_forever and get sem g_semId.\n"); 158 if (ret == LOS_OK) { 159 dprintf("ExampleSemTask1 post sem g_semId.\n"); 160 LOS_SemPost(g_semId); 161 return; 162 } 163 } 164} 165 166VOID ExampleSemTask2(VOID) 167{ 168 UINT32 ret; 169 dprintf("ExampleSemTask2 try get sem g_semId wait forever.\n"); 170 171 /* 永久阻塞模式申请信号量 */ 172 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER); 173 if (ret == LOS_OK) { 174 dprintf("ExampleSemTask2 get sem g_semId and then delay 20 ticks.\n"); 175 } 176 177 /* 任务休眠20 ticks */ 178 LOS_TaskDelay(20); 179 180 dprintf("ExampleSemTask2 post sem g_semId.\n"); 181 /* 释放信号量 */ 182 LOS_SemPost(g_semId); 183 return; 184} 185 186UINT32 ExampleSem(VOID) 187{ 188 UINT32 ret; 189 TSK_INIT_PARAM_S task1; 190 TSK_INIT_PARAM_S task2; 191 192 /* 创建信号量 */ 193 LOS_SemCreate(0, &g_semId); 194 195 /* 锁任务调度 */ 196 LOS_TaskLock(); 197 198 /* 创建任务1 */ 199 (VOID)memset_s(&task1, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S)); 200 task1.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask1; 201 task1.pcName = "TestTask1"; 202 task1.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 203 task1.usTaskPrio = TASK_PRIO_LOW; 204 ret = LOS_TaskCreate(&g_testTaskId01, &task1); 205 if (ret != LOS_OK) { 206 dprintf("task1 create failed .\n"); 207 return LOS_NOK; 208 } 209 210 /* 创建任务2 */ 211 (VOID)memset_s(&task2, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S)); 212 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask2; 213 task2.pcName = "TestTask2"; 214 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 215 task2.usTaskPrio = TASK_PRIO_HI; 216 ret = LOS_TaskCreate(&g_testTaskId02, &task2); 217 if (ret != LOS_OK) { 218 dprintf("task2 create failed.\n"); 219 return LOS_NOK; 220 } 221 222 /* 解锁任务调度 */ 223 LOS_TaskUnlock(); 224 225 /* 任务休眠400 ticks */ 226 LOS_TaskDelay(400); 227 228 ret = LOS_SemPost(g_semId); 229 230 /* 任务休眠400 ticks */ 231 LOS_TaskDelay(400); 232 233 /* 删除信号量 */ 234 LOS_SemDelete(g_semId); 235 return LOS_OK; 236} 237``` 238 239 240### 结果验证 241 242编译运行得到的结果为： 243 244 245``` 246ExampleSemTask2 try get sem g_semId wait forever. 247ExampleSemTask1 try get sem g_semId, timeout 10 ticks. 248ExampleSemTask1 timeout and try get sem g_semId wait forever. 249ExampleSemTask2 get sem g_semId and then delay 20 ticks. 250ExampleSemTask2 post sem g_semId. 251ExampleSemTask1 wait_forever and get sem g_semId. 252ExampleSemTask1 post sem g_semId. 253``` 254
