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。

相关文章

C#多线程编程中导致死锁的常见陷阱和避免方法

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁（Deadlock）是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁？死锁的典型条件：2. 导致死锁的常见原因2.1 锁的顺序问题错误示例：不同
阅读更多...
5分钟获取deepseek api并搭建简易问答应用

5分钟获取deepseek api并搭建简易问答应用

《5分钟获取deepseekapi并搭建简易问答应用》本文主要介绍了5分钟获取deepseekapi并搭建简易问答应用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需... 目录1、获取api2、获取base_url和chat_model3、配置模型参数方法一：终端中临时将加
阅读更多...
JavaScript中的isTrusted属性及其应用场景详解

JavaScript中的isTrusted属性及其应用场景详解

《JavaScript中的isTrusted属性及其应用场景详解》在现代Web开发中,JavaScript是构建交互式应用的核心语言,随着前端技术的不断发展,开发者需要处理越来越多的复杂场景,例如事件... 目录引言一、问题背景二、isTrusted 属性的来源与作用1. isTrusted 的定义2. 为
阅读更多...
PyCharm接入DeepSeek实现AI编程的操作流程

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言
阅读更多...
Python调用另一个py文件并传递参数常见的方法及其应用场景

Python调用另一个py文件并传递参数常见的方法及其应用场景

《Python调用另一个py文件并传递参数常见的方法及其应用场景》：本文主要介绍在Python中调用另一个py文件并传递参数的几种常见方法,包括使用import语句、exec函数、subproce... 目录前言1. 使用import语句1.1 基本用法1.2 导入特定函数1.3 处理文件路径2. 使用ex
阅读更多...
Kubernetes常用命令大全近期总结

Kubernetes常用命令大全近期总结

《Kubernetes常用命令大全近期总结》Kubernetes是用于大规模部署和管理这些容器的开源软件-在希腊语中,这个词还有“舵手”或“飞行员”的意思,使用Kubernetes（有时被称为“... 目录前言Kubernetes 的工作原理为什么要使用 Kubernetes？Kubernetes常用命令总
阅读更多...
将Python应用部署到生产环境的小技巧分享

将Python应用部署到生产环境的小技巧分享

《将Python应用部署到生产环境的小技巧分享》文章主要讲述了在将Python应用程序部署到生产环境之前,需要进行的准备工作和最佳实践,包括心态调整、代码审查、测试覆盖率提升、配置文件优化、日志记录完... 目录部署前夜：从开发到生产的心理准备与检查清单环境搭建：打造稳固的应用运行平台自动化流水线：让部署像
阅读更多...
Linux中Curl参数详解实践应用

Linux中Curl参数详解实践应用

《Linux中Curl参数详解实践应用》在现代网络开发和运维工作中,curl命令是一个不可或缺的工具,它是一个利用URL语法在命令行下工作的文件传输工具,支持多种协议,如HTTP、HTTPS、FTP等... 目录引言一、基础请求参数1. -X 或 --request2. -d 或 --data3. -H 或
阅读更多...
在Ubuntu上部署SpringBoot应用的操作步骤

在Ubuntu上部署SpringBoot应用的操作步骤

《在Ubuntu上部署SpringBoot应用的操作步骤》随着云计算和容器化技术的普及,Linux服务器已成为部署Web应用程序的主流平台之一,Java作为一种跨平台的编程语言,具有广泛的应用场景,本... 目录一、部署准备二、安装 Java 环境1. 安装 JDK2. 验证 Java 安装三、安装 mys
阅读更多...
Python中构建终端应用界面利器Blessed模块的使用

Python中构建终端应用界面利器Blessed模块的使用

《Python中构建终端应用界面利器Blessed模块的使用》Blessed库作为一个轻量级且功能强大的解决方案,开始在开发者中赢得口碑,今天,我们就一起来探索一下它是如何让终端UI开发变得轻松而高... 目录一、安装与配置：简单、快速、无障碍二、基本功能：从彩色文本到动态交互1. 显示基本内容2. 创建链
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2