code/sample_sem.c · LeonChan/docs

代码拉取完成,页面将自动刷新

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 10

LeonChan/docs

forked from WeHarmony/docs

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

master

分支 (1)

管理

master

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 1

标签 0

docs

code

sample_sem.c

sample_sem.c 3.55 KB

#include "los_sem.h"
#include "securec.h"

/* 任务ID */
static UINT32 g_testTaskId01;
static UINT32 g_testTaskId02;
/* 测试任务优先级 */
#define TASK_PRIO_TEST 5
/* 信号量结构体id */
static UINT32 g_semId;

VOID Example_SemTask1(VOID)
{
 UINT32 ret;

printf("Example_SemTask1 try get sem g_semId ,timeout 10 ticks.\n");
 /* 定时阻塞模式申请信号量,定时时间为10ticks */
 ret = LOS_SemPend(g_semId, 10);

/*申请到信号量*/
 if (ret == LOS_OK) {
 LOS_SemPost(g_semId);
 return;
 }
 /* 定时时间到,未申请到信号量 */
 if (ret == LOS_ERRNO_SEM_TIMEOUT) {
 printf("Example_SemTask1 timeout and try get sem g_semId wait forever.\n");
 /*永久阻塞模式申请信号量*/
 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER);
 printf("Example_SemTask1 wait_forever and get sem g_semId .\n");
 if (ret == LOS_OK) {
 LOS_SemPost(g_semId);
 return;
 }
 }
}

VOID Example_SemTask2(VOID)
{
 UINT32 ret;
 printf("Example_SemTask2 try get sem g_semId wait forever.\n");
 /* 永久阻塞模式申请信号量 */
 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER);

if (ret == LOS_OK) {
 printf("Example_SemTask2 get sem g_semId and then delay 20ticks .\n");
 }

/* 任务休眠20 ticks */
 LOS_TaskDelay(20);

printf("Example_SemTask2 post sem g_semId .\n");
 /* 释放信号量 */
 LOS_SemPost(g_semId);
 return;
}

UINT32 ExampleTaskEntry(VOID)
{
 UINT32 ret;
 TSK_INIT_PARAM_S task1;
 TSK_INIT_PARAM_S task2;

/* 创建信号量 */
 LOS_SemCreate(0,&g_semId);

/* 锁任务调度 */
 LOS_TaskLock();

/*创建任务1*/
 (VOID)memset_s(&task1, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
 task1.pfnTaskEntry = (TSK_ENTRY_FUNC)Example_SemTask1;
 task1.pcName = "TestTsk1";
 task1.uwStackSize = OS_TSK_DEFAULT_STACK_SIZE;
 task1.usTaskPrio = TASK_PRIO_TEST;
 ret = LOS_TaskCreate(&g_testTaskId01, &task1);
 if (ret != LOS_OK) {
 printf("task1 create failed .\n");
 return LOS_NOK;
 }

/* 创建任务2 */
 (VOID)memset_s(&task2, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)Example_SemTask2;
 task2.pcName = "TestTsk2";
 task2.uwStackSize = OS_TSK_DEFAULT_STACK_SIZE;
 task2.usTaskPrio = (TASK_PRIO_TEST - 1);
 ret = LOS_TaskCreate(&g_testTaskId02, &task2);
 if (ret != LOS_OK) {
 printf("task2 create failed .\n");
 return LOS_NOK;
 }

/* 解锁任务调度 */
 LOS_TaskUnlock();

ret = LOS_SemPost(g_semId);

/* 任务休眠40 ticks */
 LOS_TaskDelay(40);

/* 删除信号量 */
 LOS_SemDelete(g_semId);

/* 删除任务1 */
 ret = LOS_TaskDelete(g_testTaskId01);
 if (ret != LOS_OK) {
 printf("task1 delete failed .\n");
 return LOS_NOK;
 }
 /* 删除任务2 */
 ret = LOS_TaskDelete(g_testTaskId02);
 if (ret != LOS_OK) {
 printf("task2 delete failed .\n");
 return LOS_NOK;
 }

return LOS_OK;
}

/** 编译运行得到的结果为:
Example_SemTask2 try get sem g_semId wait forever.
Example_SemTask1 try get sem g_semId ,timeout 10 ticks.
Example_SemTask2 get sem g_semId and then delay 20ticks .
Example_SemTask1 timeout and try get sem g_semId wait forever.
Example_SemTask2 post sem g_semId .
Example_SemTask1 wait_forever and get sem g_semId .
**/

一键复制编辑原始数据按行查看历史

kuangyufei 提交于 2021年02月07日 18:16 +08:00 . https://weharmony.gitee.io/

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128

#include "los_sem.h"
#include "securec.h"

/* 任务ID */
static UINT32 g_testTaskId01;
static UINT32 g_testTaskId02;
/* 测试任务优先级 */
#define TASK_PRIO_TEST 5
/* 信号量结构体id */
static UINT32 g_semId;

VOID Example_SemTask1(VOID)
{
 UINT32 ret;

 printf("Example_SemTask1 try get sem g_semId ,timeout 10 ticks.\n");
 /* 定时阻塞模式申请信号量,定时时间为10ticks */
 ret = LOS_SemPend(g_semId, 10);

 /*申请到信号量*/
 if (ret == LOS_OK) {
 LOS_SemPost(g_semId);
 return;
 }
 /* 定时时间到,未申请到信号量 */
 if (ret == LOS_ERRNO_SEM_TIMEOUT) {
 printf("Example_SemTask1 timeout and try get sem g_semId wait forever.\n");
 /*永久阻塞模式申请信号量*/
 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER);
 printf("Example_SemTask1 wait_forever and get sem g_semId .\n");
 if (ret == LOS_OK) {
 LOS_SemPost(g_semId);
 return;
 }
 }
}

VOID Example_SemTask2(VOID)
{
 UINT32 ret;
 printf("Example_SemTask2 try get sem g_semId wait forever.\n");
 /* 永久阻塞模式申请信号量 */
 ret = LOS_SemPend(g_semId, LOS_WAIT_FOREVER);

 if (ret == LOS_OK) {
 printf("Example_SemTask2 get sem g_semId and then delay 20ticks .\n");
 }

 /* 任务休眠20 ticks */
 LOS_TaskDelay(20);

 printf("Example_SemTask2 post sem g_semId .\n");
 /* 释放信号量 */
 LOS_SemPost(g_semId);
 return;
}

UINT32 ExampleTaskEntry(VOID)
{
 UINT32 ret;
 TSK_INIT_PARAM_S task1;
 TSK_INIT_PARAM_S task2;

 /* 创建信号量 */
 LOS_SemCreate(0,&g_semId);

 /* 锁任务调度 */
 LOS_TaskLock();

 /*创建任务1*/
 (VOID)memset_s(&task1, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
 task1.pfnTaskEntry = (TSK_ENTRY_FUNC)Example_SemTask1;
 task1.pcName = "TestTsk1";
 task1.uwStackSize = OS_TSK_DEFAULT_STACK_SIZE;
 task1.usTaskPrio = TASK_PRIO_TEST;
 ret = LOS_TaskCreate(&g_testTaskId01, &task1);
 if (ret != LOS_OK) {
 printf("task1 create failed .\n");
 return LOS_NOK;
 }

 /* 创建任务2 */
 (VOID)memset_s(&task2, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)Example_SemTask2;
 task2.pcName = "TestTsk2";
 task2.uwStackSize = OS_TSK_DEFAULT_STACK_SIZE;
 task2.usTaskPrio = (TASK_PRIO_TEST - 1);
 ret = LOS_TaskCreate(&g_testTaskId02, &task2);
 if (ret != LOS_OK) {
 printf("task2 create failed .\n");
 return LOS_NOK;
 }

 /* 解锁任务调度 */
 LOS_TaskUnlock();

 ret = LOS_SemPost(g_semId);

 /* 任务休眠40 ticks */
 LOS_TaskDelay(40);

 /* 删除信号量 */
 LOS_SemDelete(g_semId);

 /* 删除任务1 */
 ret = LOS_TaskDelete(g_testTaskId01);
 if (ret != LOS_OK) {
 printf("task1 delete failed .\n");
 return LOS_NOK;
 }
 /* 删除任务2 */
 ret = LOS_TaskDelete(g_testTaskId02);
 if (ret != LOS_OK) {
 printf("task2 delete failed .\n");
 return LOS_NOK;
 }

 return LOS_OK;
}

/** 编译运行得到的结果为:
Example_SemTask2 try get sem g_semId wait forever.
Example_SemTask1 try get sem g_semId ,timeout 10 ticks.
Example_SemTask2 get sem g_semId and then delay 20ticks .
Example_SemTask1 timeout and try get sem g_semId wait forever.
Example_SemTask2 post sem g_semId .
Example_SemTask1 wait_forever and get sem g_semId .
**/