1# 互斥锁 2 3 4## 基本概念 5 6互斥锁又称互斥型信号量，是一种特殊的二值性信号量，用于实现对共享资源的独占式处理。 7 8任意时刻互斥锁的状态只有两种，开锁或闭锁。当任务持有互斥锁时，该互斥锁处于闭锁状态，这个任务获得该互斥锁的所有权。当该任务释放互斥锁时，该互斥锁被开锁，任务失去该互斥锁的所有权。当一个任务持有互斥锁时，其他任务将不能再对该互斥锁进行开锁或持有。 9 10多任务环境下往往存在多个任务竞争同一共享资源的应用场景，互斥锁可被用于对共享资源的保护从而实现独占式访问。另外互斥锁可以解决信号量存在的优先级翻转问题。 11 12 13## 运行机制 14 15多任务环境下会存在多个任务访问同一公共资源的场景，而有些公共资源是非共享的，需要任务进行独占式处理。互斥锁怎样来避免这种冲突呢？ 16 17用互斥锁处理非共享资源的同步访问时，如果有任务访问该资源，则互斥锁为加锁状态。此时其他任务如果想访问这个公共资源则会被阻塞，直到互斥锁被持有该锁的任务释放后，其他任务才能重新访问该公共资源，此时互斥锁再次上锁，如此确保同一时刻只有一个任务正在访问这个公共资源，保证了公共资源操作的完整性。 18 19 **图1** 轻量系统互斥锁运作示意图 20 21  22 23 24## 接口说明 25 26 **表1** 互斥锁模块接口 27 28| 功能分类 | 接口描述 | 29| -------- | -------- | 30| 互斥锁的创建和删除 | LOS_MuxCreate：创建互斥锁。<br/>LOS_MuxDelete：删除指定的互斥锁。 | 31| 互斥锁的申请和释放 | LOS_MuxPend：申请指定的互斥锁。<br/>LOS_MuxPost：释放指定的互斥锁。 | 32 33 34## 开发流程 35 36互斥锁典型场景的开发流程： 37 381. 创建互斥锁LOS_MuxCreate。 39 402. 申请互斥锁LOS_MuxPend。 41 申请模式有三种：无阻塞模式、永久阻塞模式、定时阻塞模式。 42 43 - 无阻塞模式：任务需要申请互斥锁，若该互斥锁当前没有任务持有，或者持有该互斥锁的任务和申请该互斥锁的任务为同一个任务，则申请成功。否则直接返回并继续运行当前任务，不会产生阻塞。 44 - 永久阻塞模式：任务需要申请互斥锁，若该互斥锁当前没有被占用，则申请成功。否则，该任务进入阻塞态，系统切换到就绪任务中优先级高者继续执行。任务进入阻塞态后，直到有其他任务释放该互斥锁，阻塞任务才会重新得以执行。 45 - 定时阻塞模式：任务需要申请互斥锁，若该互斥锁当前没有被占用，则申请成功。否则该任务进入阻塞态，系统切换到就绪任务中优先级高者继续执行。任务进入阻塞态后，指定时间超时前有其他任务释放该互斥锁，或者用户指定时间超时后，阻塞任务才会重新得以执行。 46 473. 释放互斥锁LOS_MuxPost。 48 - 如果有任务阻塞于指定互斥锁，则唤醒被阻塞任务中优先级高的，该任务进入就绪态，并进行任务调度； 49 - 如果没有任务阻塞于指定互斥锁，则互斥锁释放成功。 50 514. 删除互斥锁LOS_MuxDelete。 52 53>  **说明：** 54> - 互斥锁支持嵌套，即申请该互斥锁的任务与已经持有该互斥锁的任务为同一个任务时会认为申请成功，按申请次数对应的去释放该锁即可。 55> 56> - 互斥锁不能在中断服务程序中使用。 57> 58> - LiteOS-M内核作为实时操作系统需要保证任务调度的实时性，尽量避免任务的长时间阻塞，因此在获得互斥锁之后，应该尽快释放互斥锁。 59> 60> - 持有互斥锁的过程中，不得再调用LOS_TaskPriSet等接口更改持有互斥锁任务的优先级。 61 62 63## 编程实例 64 65 66### 实例描述 67 68本实例实现如下流程。 69 701. 任务ExampleMutex创建一个互斥锁，锁任务调度，创建两个任务ExampleMutexTask1、ExampleMutexTask2。ExampleMutexTask2优先级高于ExampleMutexTask1，解锁任务调度。 71 722. ExampleMutexTask2被调度，以永久阻塞模式申请互斥锁，并成功获取到该互斥锁，然后任务休眠100Tick，ExampleMutexTask2挂起，ExampleMutexTask1被唤醒。 73 743. ExampleMutexTask1以定时阻塞模式申请互斥锁，等待时间为10Tick，因互斥锁仍被ExampleMutexTask2持有，ExampleMutexTask1挂起。10Tick超时时间到达后，ExampleMutexTask1被唤醒，以永久阻塞模式申请互斥锁，因互斥锁仍被ExampleMutexTask2持有，ExampleMutexTask1挂起。 75 764. 100Tick休眠时间到达后，ExampleMutexTask2被唤醒， 释放互斥锁，唤醒ExampleMutexTask1。ExampleMutexTask1成功获取到互斥锁后，释放并删除互斥锁。 77 78 79### 示例代码 80 81示例代码如下： 82 83本演示代码在 ./kernel/liteos_m/testsuites/src/osTest.c 中编译验证，在TestTaskEntry中调用验证入口函数ExampleMutex。 84 85 86``` 87#include "los_mux.h" 88 89/* 互斥锁句柄 */ 90UINT32 g_testMux; 91 92VOID ExampleMutexTask1(VOID) 93{ 94 UINT32 ret; 95 96 printf("task1 try to get mutex, wait 10 ticks.\n"); 97 /* 申请互斥锁 */ 98 ret = LOS_MuxPend(g_testMux, 10); 99 if (ret == LOS_OK) { 100 printf("task1 get mutex g_testMux.\n"); 101 /* 释放互斥锁，这个分支正常不应该进来 */ 102 LOS_MuxPost(g_testMux); 103 LOS_MuxDelete(g_testMux); 104 return; 105 } 106 107 if (ret == LOS_ERRNO_MUX_TIMEOUT ) { 108 printf("task1 timeout and try to get mutex, wait forever.\n"); 109 /* 申请互斥锁 */ 110 ret = LOS_MuxPend(g_testMux, LOS_WAIT_FOREVER); 111 if (ret == LOS_OK) { 112 printf("task1 wait forever, get mutex g_testMux.\n"); 113 /* 释放互斥锁 */ 114 LOS_MuxPost(g_testMux); 115 /* 删除互斥锁 */ 116 LOS_MuxDelete(g_testMux); 117 printf("task1 post and delete mutex g_testMux.\n"); 118 return; 119 } 120 } 121 122 return; 123} 124 125VOID ExampleMutexTask2(VOID) 126{ 127 printf("task2 try to get mutex, wait forever.\n"); 128 /* 申请互斥锁 */ 129 (VOID)LOS_MuxPend(g_testMux, LOS_WAIT_FOREVER); 130 printf("task2 get mutex g_testMux and suspend 100 ticks.\n"); 131 132 /* 任务休眠100Ticks */ 133 LOS_TaskDelay(100); 134 135 printf("task2 resumed and post the g_testMux\n"); 136 /* 释放互斥锁 */ 137 LOS_MuxPost(g_testMux); 138 return; 139} 140 141UINT32 ExampleMutex(VOID) 142{ 143 UINT32 ret; 144 TSK_INIT_PARAM_S task1 = { 0 }; 145 TSK_INIT_PARAM_S task2 = { 0 }; 146 UINT32 taskId01; 147 UINT32 taskId02; 148 149 /* 创建互斥锁 */ 150 LOS_MuxCreate(&g_testMux); 151 152 /* 锁任务调度 */ 153 LOS_TaskLock(); 154 155 /* 创建任务1 */ 156 task1.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleMutexTask1; 157 task1.pcName = "MutexTsk1"; 158 task1.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 159 task1.usTaskPrio = 5; 160 ret = LOS_TaskCreate(&taskId01, &task1); 161 if (ret != LOS_OK) { 162 printf("task1 create failed.\n"); 163 return LOS_NOK; 164 } 165 166 /* 创建任务2 */ 167 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleMutexTask2; 168 task2.pcName = "MutexTsk2"; 169 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 170 task2.usTaskPrio = 4; 171 ret = LOS_TaskCreate(&taskId02, &task2); 172 if (ret != LOS_OK) { 173 printf("task2 create failed.\n"); 174 return LOS_NOK; 175 } 176 177 /* 解锁任务调度 */ 178 LOS_TaskUnlock(); 179 180 return LOS_OK; 181} 182``` 183 184 185### 结果验证 186 187 编译运行得到的结果为： 188 189``` 190task2 try to get mutex, wait forever. 191task2 get mutex g_testMux and suspend 100 ticks. 192task1 try to get mutex, wait 10 ticks. 193task1 timeout and try to get mutex, wait forever. 194task2 resumed and post the g_testMux 195task1 wait forever, get mutex g_testMux. 196task1 post and delete mutex g_testMux. 197``` 198
