第7章任务间的同步与通讯之消息队列讲述.ppt

第7章任务间的同步与通讯之消息队列讲述.ppt

  1. 1、本文档共51页,可阅读全部内容。
  2. 2、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
  3. 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载
  4. 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
查看更多
第7章任务间的同步与通讯之消息队列讲述

示例 OS_EVENT *TaskQ; void Task(void *pdata){ INT8U err; void *msg; pdata = pdata; for (;;) { msg = OSQPend(TaskQ, 100, err); if (err = = OS_NO_ERR) { . /*在指定时间内接收到消息 要做的事情*/} else { /*在指定的时间内没有接收到指定的消息 要做的事情 */ } } } 说明 如果调用OSQPend()函数时队列中已经存在需要的消息,那么该消息被返回给OSQPend()函数的调用者,队列中清除该消息。 如果调用OSQPend()函数时队列中没有需要的消息,OSQPend()函数挂起当前任务直到得到需要的消息或超出定义的超时时间。 如果同时有多个任务等待同一个消息,μC/OS-Ⅱ默认最高优先级的任务取得消息并且任务恢复执行。 一个由OSTaskSuspend()函数挂起的任务也可以接受消息,但这个任务将一直保持挂起状态直到通过调用OSTaskResume()函数恢复任务的运行。 消息队列的操作 OSQCreate() OSQDel() OSQPend() OSQPost() OSQPostFront() OSQPostOpt() OSQAccept() OSQFlush() OSQQuery() 向消息队列发送一个消息(FIFO),OSQPost() OSQPost()的函数原型如下: INT8U OSQPost(OS_EVENT *pevent, void *msg); 参数: pevent:指向即将接收消息的消息队列的指针。该指针的值在建立该队列时可以得到。(参考OSQCreate()函数)。 msg:即将实际发送给任务的消息。消息是一个指针长度的变量,在不同的程序中消息的使用也可能不同。不允许传递一个空指针。 返回值: OS_NO_ERR :消息成功的放到消息队列中。 OS_MBOX_FULL :消息队列已满。 OS_ERR_EVENT_TYPE :pevent 不是指向消息队列的指针。 示例 OS_EVENT *TaskQ; INT8U RxBuf[50]; void TaskRx(void *pdata){ INT8U err; pdata = pdata; for (;;) { . err = OSQPost(TaskQ, (void *) RxBuf[0]); if (err == OS_NO_ERR) { . } else { . } } } 消息队列的操作 OSQCreate() OSQDel() OSQPend() OSQPost() OSQPostFront() OSQPostOpt() OSQAccept() OSQFlush() OSQQuery() 向消息队列发送一个消息(LIFO),OSQPostFront() 函数OSQPostFront()以LIFO(后进先出)的方式组织消息队列。 OSQPostFront()函数的原型如下: INT8U OSQPostFront(OS_EVENT *pevent, void *msg); 参数: pevent:指向即将接收消息的消息队列的指针。 msg:即将实际发送给任务的消息。消息是一个指针长度的变量,在不同的程序中消息的使用也可能不同。不允许传递一个空指针。 返回值: OS_NO_ERR:消息成功的放到消息队列中。 OS_Q_FULL:消息队列已满。 OS_ERR_EVENT_TYPE:pevent 不是指向消息队列的指针。 ?OS_ERR_PEVENT_NULL:pevent是空指针。 ?OS_ERR_POST_NULL_PTR:发出空指针。 示例 OS_EVENT *TaskQ; INT8U RxBuf[50]; void Task (void *pdata){ INT8U err; pdata = pdata; for (; ;) { . err = OSQPostFront(TaskQ, (void *)RxBuf[0]); if (err = = OS_

文档评论(0)

shuwkb + 关注
实名认证
内容提供者

该用户很懒,什么也没介绍

1亿VIP精品文档

相关文档