ucos:ucos 应用编程大全

2024-02-12 04:18
文章标签 应用 编程 大全 ucos

本文主要是介绍ucos:ucos 应用编程大全，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

0：ucos for linux port 代码
     ucos for linux port代码可以在： 我的资源中下载。

1：说明

主要对ucos中的task创建，消息队列，消息邮箱，信号量，互斥量的使用进行了举例说明。
对不同的模块的测试：可以通过不同的宏定义来实现。
#define UCOS_BASIC_TASK_TEST   0  //基本任务的创建
#define UCOS_MSG_QUEUE_TASK_TEST 0  //消息队列
#define UCOS_MAIL_B0X_TASK_TEST 0 //消息邮箱
#define UCOS_MEM_TASK_TEST          0 //内存管理
#define UCOS_SEM_TASK_TEST          0 //信号量
#define UCOS_MUTEX_TASK_TEST        1 //互斥量

对不同的模块的测试：可以通过不同的宏定义来实现。
#define UCOS_BASIC_TASK_TEST  0//基本任务的创建
#define UCOS_MSG_QUEUE_TASK_TEST0//消息队列
#define UCOS_MAIL_B0X_TASK_TEST0//消息邮箱
#define UCOS_MEM_TASK_TEST         0//内存管理
#define UCOS_SEM_TASK_TEST         0//信号量
#define UCOS_MUTEX_TASK_TEST       1//互斥量

2：示例代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "ucos_ii.h"typedef unsigned char uint8 ;
typedef unsigned short uint16;
struct msgbuf {uint8  option;                 /* Message type */uint8  msgID;uint16 msgData;
};
struct msgType {long mtype;struct msgbuf mdata;
};
#define  TASK_STK_SIZE    128
#define  BUFFER_SIZE  	  3struct storage_data
{INT16U input;INT16U output;INT16U buffer[BUFFER_SIZE];
};
OS_STK        AppStk_send_one[TASK_STK_SIZE];
OS_STK        AppStk_send_two[TASK_STK_SIZE];
OS_STK        AppStk_recv[TASK_STK_SIZE];
OS_STK        qsmBox_AppStk_send[TASK_STK_SIZE];
OS_STK        qsmBox_AppStk_recv[TASK_STK_SIZE];
OS_STK        mem_AppStk_one[TASK_STK_SIZE];
OS_STK        mem_AppStk_two[TASK_STK_SIZE];
OS_STK        sem_AppStk_producer[TASK_STK_SIZE];
OS_STK        sem_AppStk_customer[TASK_STK_SIZE];
OS_STK        mutex_Stack1[TASK_STK_SIZE];
OS_STK        mutex_Stack2[TASK_STK_SIZE];
OS_MEM *mem_p;
OS_EVENT  *pmsgqueue;
OS_EVENT  *pmailbox;
OS_EVENT  *sem_custom;
OS_EVENT  *sem_produce;
OS_EVENT  *ResourceMutex;
void *ptr;
void *msgqueue[10];
struct storage_data *storage;
static int g_counter=0;unsigned long long monotonic_us(void)
{struct timeval tv;gettimeofday(&tv, NULL);return tv.tv_sec * 1000000ULL + tv.tv_usec;
}
void printf_task_info(uint8 i)
{if(OSTCBPrioTbl[i]==NULL){printf("the prio=%u task is no exit\n",i);return ;}else{OS_Printf("the prio=%u task information as follow\n",i);OS_Printf("the prio=%u task delay time is %u\n",i,OSTCBPrioTbl[i]->OSTCBDly);OS_Printf("the prio=%u task status is 0x%x\n",i,OSTCBPrioTbl[i]->OSTCBStat);OS_Printf("the prio=%u task name is %s\n",i,OSTCBPrioTbl[i]->OSTCBTaskName);OS_Printf("OSTCBCur->OSTCBStkPtr=%p\n",OSTCBCur->OSTCBStkPtr);OS_Printf("current task prio=%u\n",OSPrioCur);return ;}
}
void MyTask( void *p_arg )
{char* sTaskName = (char*)p_arg;while(1){/* printf uses mutex to get terminal access, therefore must enter critical section */OS_Printf("%s\t%s: line: %d Name: %s\n", __FILE__,__func__, __LINE__, sTaskName );/* Delay so other tasks may execute. */OSTimeDlyHMSM(0, 0,0 , 50);}/* while */}void App_send_one(void *p_arg)
{INT8U  err;struct msgType sendMsg;struct msgType *recvdMsg;memset(&sendMsg,0,sizeof(sendMsg));p_arg = p_arg;OSTaskNameSet(OSPrioCur,"App_send_one",&err);while(1)                            { srand(monotonic_us());sendMsg.mtype=0x01;sendMsg.mdata.option=0x01;sendMsg.mdata.msgID=0x01;sendMsg.mdata.msgData=rand();recvdMsg =&sendMsg;if((err=OSQPost(pmsgqueue,(void *)&sendMsg))==OS_NO_ERR){OS_Printf("App_send_one: mtype:%d option:%d msgID:%d msgData:%d\n",recvdMsg->mtype,recvdMsg->mdata.option ,recvdMsg->mdata.msgID, recvdMsg->mdata.msgData);}else if(err==OS_Q_FULL){OS_Printf("this is senderone the msg_q is full\n");}else{OS_Printf("other err\n");}OSTimeDlyHMSM(0, 0, 0, 20);//	printf_task_info(OSPrioCur);}
}void App_send_two(void *p_arg)
{INT8U err;p_arg = p_arg;struct msgType sendMsg;struct msgType *recvdMsg;memset(&sendMsg,0,sizeof(sendMsg));OSTaskNameSet(OSPrioCur,"App_send_two",&err);while(1)                           { srand(monotonic_us());sendMsg.mtype=0x02;sendMsg.mdata.option=0x02;sendMsg.mdata.msgID=0x02;sendMsg.mdata.msgData=rand();recvdMsg =&sendMsg;if((err=OSQPost(pmsgqueue,&sendMsg))==OS_NO_ERR){OS_Printf("App_send_two: mtype:%d option:%d msgID:%d msgData:%d\n",recvdMsg->mtype,recvdMsg->mdata.option ,recvdMsg->mdata.msgID, recvdMsg->mdata.msgData);}else if(err==OS_Q_FULL){OS_Printf("this is sendertwo\nthe msg_q is full\n");}else{OS_Printf("other err\n");}OSTimeDlyHMSM(0, 0, 2, 0);sendMsg.mtype=0x03;sendMsg.mdata.option=0x03;sendMsg.mdata.msgID=0x03;sendMsg.mdata.msgData=rand();recvdMsg =&sendMsg;if((err=OSQPostFront(pmsgqueue,&sendMsg))==OS_NO_ERR){OS_Printf("App_send_two: mtype:%d option:%d msgID:%d msgData:%d\n",recvdMsg->mtype,recvdMsg->mdata.option ,recvdMsg->mdata.msgID, recvdMsg->mdata.msgData);}else if(err==OS_Q_FULL){OS_Printf("this is sendertwo the msg_q is full\n");}else{OS_Printf("other err\n");}OSTimeDlyHMSM(0, 0, 0, 10);//printf_task_info(OSPrioCur);}
}void App_recv(void *p_arg)
{INT8U err;INT16U timeout=100;struct msgType *recvdMsg;p_arg = p_arg;OS_Printf("when create:\n");pmsgqueue=OSQCreate(msgqueue,10);for (;;){recvdMsg=OSQPend(pmsgqueue,timeout,&err);if(err==OS_NO_ERR){OS_Printf("recver data is: mtype:%d option:%d msgID:%d msgData:%d\n",recvdMsg->mtype,recvdMsg->mdata.option ,recvdMsg->mdata.msgID, recvdMsg->mdata.msgData);}else if(err==OS_TIMEOUT){OS_Printf("timeout\n");break;}else if(err==OS_ERR_EVENT_TYPE){	OS_Printf("this is recver err is OS_ERR_EVENT_TYP\n");break;}else{break;}OSTimeDlyHMSM(0, 0, 0, 1);}OSQDel(pmsgqueue,OS_DEL_NO_PEND, &err);if(err==OS_ERR_TASK_WAITING){OS_Printf("some task wait for this Mailbox\n");}
}
void qsmBox_App_send(void *p_arg)
{INT8U i;INT8U err;INT8U *buffer[3];buffer[0]="test01\n";buffer[1]="test02\n";buffer[2]="test03\n";p_arg = p_arg;pmailbox=OSMboxCreate(NULL);while(1){for (i=0;i<=2;){if((err=OSMboxPost(pmailbox,buffer[i]))==OS_NO_ERR){OS_Printf("qsmBox_App_send,data is: %s\n",buffer[i]);i++;}else if(err==OS_MBOX_FULL){OS_Printf("this is sender\nthe Mailbox has data,data is: %s\n",pmailbox->OSEventPtr);}else{OS_Printf("other err\n");}OSTimeDlyHMSM(0, 0, 0, 25);}}OSTimeDlyHMSM(0, 0, 5, 0);OSMboxDel (pmailbox,OS_DEL_NO_PEND, &err);if(err==OS_ERR_TASK_WAITING){OS_Printf("some task wait for this Mailbox\n");}
}void qsmBox_App_recv(void *p_arg)
{INT8U err;INT16U timeout=100;INT8U *buffer;p_arg = p_arg;for (;;){buffer=OSMboxPend(pmailbox,timeout,&err);if(err==OS_NO_ERR){OS_Printf("qsmBox_App_recv data is: %s\n",buffer);}else if(err==OS_TIMEOUT){OS_Printf("timeout\n");}else if(err==OS_ERR_EVENT_TYPE){OS_Printf("this is recver\nerr is OS_ERR_EVENT_TYP\n");break;}else{break;}OSTimeDlyHMSM(0, 0, 0, 10);}
}
void mem_App_one(void *p_arg)
{INT8U err;INT8U *string="test memory";p_arg = p_arg;ptr=malloc(10*1024);mem_p=OSMemCreate (ptr, 10, 1024, &err);OSMemNameSet (mem_p, string, &err);output("after create:",mem_p);OSTimeDlyHMSM(0, 0, 2, 0);output("\nafter get twice:",mem_p);OSTimeDlyHMSM(0, 0, 2, 0);output("\nafter release one:",mem_p);
}void mem_App_two(void *p_arg)
{INT8U err;void *ptr[10];p_arg = p_arg;printf("\nfirst get:\n");ptr[0]=OSMemGet (mem_p, &err);printf("ptr[0]=%p\n",ptr[0]);printf("second get:\n");ptr[1]=OSMemGet (mem_p, &err);printf("ptr[1]=%p\n",ptr[1]);OSTimeDlyHMSM(0, 0, 3, 0);OSMemPut (mem_p, ptr[1]);
}void output(char *info,OS_MEM *p)
{printf("%s\n",info);printf("OSMemAddr=%p\n",p->OSMemAddr);printf("OSMemFreeList=%p\n",p->OSMemFreeList);printf("OSMemBlkSize=%d\n",p->OSMemBlkSize);printf("OSMemName=%s\n",p->OSMemName);printf("OSMemNFree=%d\n",p->OSMemNFree);printf("OSMemNBlks=%d\n",p->OSMemNBlks);
}
void sem_App_producer(void *p_arg)
{INT16U i;INT16U timeout;INT8U err;timeout=30000;storage=malloc(sizeof(struct storage_data));sem_produce=OSSemCreate(BUFFER_SIZE);sem_custom=OSSemCreate(0);sem_init();for(i=1;;){OSSemPend (sem_produce, timeout, &err);if(err==OS_NO_ERR){storage->buffer[storage->input]=i;storage->input++;i++;if (storage->input >= BUFFER_SIZE){storage->input = 0;}sem_info();OSSemPost(sem_custom);}else if(err==OS_TIMEOUT){continue;}else{printf("other error %d\n",err);break;}OSTimeDlyHMSM(0, 0, 0, 10);}
}void sem_App_customer(void *p_arg)
{INT16U i;INT16U data;INT16U timeout;INT8U err;timeout=30000;for(i=1;;){OSSemPend (sem_custom, timeout, &err);if(err==OS_NO_ERR){data=storage->buffer[storage->output];storage->buffer[storage->output]=0;printf("consume data %d\n",data);storage->output++;i++;if(storage->output >= BUFFER_SIZE){storage->output = 0;}sem_info();OSSemPost(sem_produce);}else if(err==OS_TIMEOUT){continue;	}else{printf("other error abc\n");break;}OSTimeDlyHMSM(0, 0, 3, 10);}
}void sem_init()
{int j;storage->input=0;storage->output=0;for(j=0;j<BUFFER_SIZE;j++){storage->buffer[j]=0;}
}void sem_info()
{int j;for(j=0;j<BUFFER_SIZE;j++){printf("buffer[%d]=%u\t",j,storage->buffer[j]);}printf("storage->input=%u\t",storage->input);printf("storage->output=%u\n",storage->output);
}static void mutex_Task1(void *p_arg)
{uint8  err;p_arg=p_arg;
#if OS_CRITICAL_METHOD == 3OS_CPU_SR  cpu_sr;
#endifResourceMutex= OSMutexCreate(9,&err);  while(1){OSMutexPend(ResourceMutex,0,&err);OS_ENTER_CRITICAL();g_counter++;OS_EXIT_CRITICAL();  OSMutexPost(ResourceMutex);OSTimeDly(OS_TICKS_PER_SEC*2);OS_Printf("g_counter:%ld\n",g_counter);}
}static void mutex_Task2(void *p_arg)
{   uint8  err;p_arg=p_arg;
#if OS_CRITICAL_METHOD == 3OS_CPU_SR  cpu_sr;
#endifwhile(1){OSMutexPend(ResourceMutex,0,&err);OS_ENTER_CRITICAL();g_counter++;OS_EXIT_CRITICAL(); OSMutexPost(ResourceMutex);OSTimeDly(OS_TICKS_PER_SEC);OS_Printf("g_counter:%ld\n",g_counter);}
}
#define UCOS_BASIC_TASK_TEST  			0
#define UCOS_MSG_QUEUE_TASK_TEST		0
#define UCOS_MAIL_B0X_TASK_TEST			0
#define UCOS_MEM_TASK_TEST          0
#define UCOS_SEM_TASK_TEST          0
#define UCOS_MUTEX_TASK_TEST        1
int main (void)
{uint8 Stk1[TASK_STK_SIZE];uint8 Stk2[TASK_STK_SIZE];char sTask1[] = "Task 1";char sTask2[] = "Task 2";OSInit();
#if UCOS_BASIC_TASK_TESTOSTaskCreate(App_recv,NULL,(OS_STK *)&AppStk_recv[TASK_STK_SIZE-1],(INT8U)4);OSTaskCreate( MyTask, sTask2, (OS_STK *)&Stk2[TASK_STK_SIZE-1], 5 );
#endif	#if UCOS_MSG_QUEUE_TASK_TEST0		OSTaskCreate(App_send_one,NULL,(OS_STK *)&AppStk_send_one[TASK_STK_SIZE-1],(INT8U)11);OSTaskCreate(App_send_two,NULL,(OS_STK *)&AppStk_send_two[TASK_STK_SIZE-1],(INT8U)12);OSTaskCreate(MyTask, sTask1, (OS_STK *)&Stk1[TASK_STK_SIZE-1], 13);
#endif	#if UCOS_MAIL_B0X_TASK_TEST	OSTaskCreate(qsmBox_App_send,NULL,(OS_STK *)&qsmBox_AppStk_send[TASK_STK_SIZE-1],(INT8U)14);OSTaskCreate(qsmBox_App_recv,NULL,(OS_STK *)&qsmBox_AppStk_recv[TASK_STK_SIZE-1],(INT8U)35);
#endif#if UCOS_MEM_TASK_TESTOSTaskCreate(mem_App_one,NULL,(OS_STK *)&mem_AppStk_one[TASK_STK_SIZE-1],(INT8U)16);OSTaskCreate(mem_App_two,NULL,(OS_STK *)&mem_AppStk_two[TASK_STK_SIZE-1],(INT8U)17);
#endif#if UCOS_SEM_TASK_TESTOSTaskCreate(sem_App_producer,NULL,(OS_STK *)&sem_AppStk_producer[TASK_STK_SIZE-1],(INT8U)18);OSTaskCreate(sem_App_customer,NULL,(OS_STK *)&sem_AppStk_customer[TASK_STK_SIZE-1],(INT8U)19);
#endif#if UCOS_MUTEX_TASK_TESTOSTaskCreate(mutex_Task1,NULL,(OS_STK *)&mutex_Stack1[TASK_STK_SIZE-1],(INT8U)20);OSTaskCreate(mutex_Task2,NULL,(OS_STK *)&mutex_Stack2[TASK_STK_SIZE-1],(INT8U)21);
#endifOSStart();return 0;
}


这篇关于ucos:ucos 应用编程大全的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/701653。

相关文章

PHP应用中处理限流和API节流的最佳实践

PHP应用中处理限流和API节流的最佳实践

《PHP应用中处理限流和API节流的最佳实践》限流和API节流对于确保Web应用程序的可靠性、安全性和可扩展性至关重要,本文将详细介绍PHP应用中处理限流和API节流的最佳实践,下面就来和小编一起学习... 目录限流的重要性在 php 中实施限流的最佳实践使用集中式存储进行状态管理（如 Redis）采用滑动
阅读更多...
深入浅出Spring中的@Autowired自动注入的工作原理及实践应用

深入浅出Spring中的@Autowired自动注入的工作原理及实践应用

《深入浅出Spring中的@Autowired自动注入的工作原理及实践应用》在Spring框架的学习旅程中,@Autowired无疑是一个高频出现却又让初学者头疼的注解,它看似简单,却蕴含着Sprin... 目录深入浅出Spring中的@Autowired：自动注入的奥秘什么是依赖注入？@Autowired
阅读更多...
Android协程高级用法大全

Android协程高级用法大全

《Android协程高级用法大全》这篇文章给大家介绍Android协程高级用法大全,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友跟随小编一起学习吧... 目录1️⃣ 协程作用域（CoroutineScope）与生命周期绑定Activity/Fragment 中手
阅读更多...
PostgreSQL简介及实战应用

PostgreSQL简介及实战应用

《PostgreSQL简介及实战应用》PostgreSQL是一种功能强大的开源关系型数据库管理系统,以其稳定性、高性能、扩展性和复杂查询能力在众多项目中得到广泛应用,本文将从基础概念讲起,逐步深入到高... 目录前言1. PostgreSQL基础1.1 PostgreSQL简介1.2 基础语法1.3 数据库
阅读更多...
Python异步编程之await与asyncio基本用法详解

Python异步编程之await与asyncio基本用法详解

《Python异步编程之await与asyncio基本用法详解》在Python中,await和asyncio是异步编程的核心工具,用于高效处理I/O密集型任务（如网络请求、文件读写、数据库操作等）,接... 目录一、核心概念二、使用场景三、基本用法1. 定义协程2. 运行协程3. 并发执行多个任务四、关键
阅读更多...
Python文本相似度计算的方法大全

Python文本相似度计算的方法大全

《Python文本相似度计算的方法大全》文本相似度是指两个文本在内容、结构或语义上的相近程度,通常用0到1之间的数值表示,0表示完全不同,1表示完全相同,本文将深入解析多种文本相似度计算方法,帮助您选... 目录前言什么是文本相似度？1. Levenshtein 距离（编辑距离）核心公式实现示例2. Jac
阅读更多...
AOP编程的基本概念与idea编辑器的配合体验过程

AOP编程的基本概念与idea编辑器的配合体验过程

《AOP编程的基本概念与idea编辑器的配合体验过程》文章简要介绍了AOP基础概念,包括Before/Around通知、PointCut切入点、Advice通知体、JoinPoint连接点等,说明它们... 目录BeforeAroundAdvise — 通知PointCut — 切入点Acpect — 切面
阅读更多...
Python中的filter() 函数的工作原理及应用技巧

Python中的filter() 函数的工作原理及应用技巧

《Python中的filter()函数的工作原理及应用技巧》Python的filter()函数用于筛选序列元素,返回迭代器,适合函数式编程,相比列表推导式,内存更优,尤其适用于大数据集,结合lamb... 目录前言一、基本概念基本语法二、使用方式1. 使用 lambda 函数2. 使用普通函数3. 使用 N
阅读更多...
Python中yield的用法和实际应用示例

Python中yield的用法和实际应用示例

《Python中yield的用法和实际应用示例》在Python中,yield关键字主要用于生成器函数（generatorfunctions）中,其目的是使函数能够像迭代器一样工作,即可以被遍历,但不会... 目录python中yield的用法详解一、引言二、yield的基本用法1、yield与生成器2、yi
阅读更多...
Python多线程应用中的卡死问题优化方案指南

Python多线程应用中的卡死问题优化方案指南

《Python多线程应用中的卡死问题优化方案指南》在利用Python语言开发某查询软件时,遇到了点击搜索按钮后软件卡死的问题,本文将简单分析一下出现的原因以及对应的优化方案,希望对大家有所帮助... 目录问题描述优化方案1. 网络请求优化2. 多线程架构优化3. 全局异常处理4. 配置管理优化优化效果1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2