IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 数据结构与算法 -> RT_Thread内部机制——消息队列 -> 正文阅读

[数据结构与算法]RT_Thread内部机制——消息队列

1、消息队列分为?

1.1、空闲消息队列

????????由链表msg_queue_free来指示;

1.2、数据消息队列

????????队头是链表msg_queue_head,队尾是链表msg_queue_tail

2、消息队列如何读写数据?

2.1、写

msg_queue_free拿一个消息块来放数据,msg_queue_free指向下一个空消息块,这个存有数据的消息块排到队尾msg_queue_tail;

如果没有空间可写,可挂起到suspend_sender_thread

2.2、读

队头msg_queue_head取出消息块,msg_queue_head指向数据消息队列next,读完后的消息块成为空闲消息块插入msg_queue_free的头;

如果没有数据可读,可挂起到suspend_thread;

3、rt_mq_create里如何初始化消息队列?

4、发送消息的过程

rt_err_t rt_mq_send_wait(rt_mq_t     mq,
                         const void *buffer,
                         rt_size_t   size,
                         rt_int32_t  timeout)
{
    //获取空闲消息队列
    msg = (struct rt_mq_message *)mq->msg_queue_free;

    //如果无空闲块,且不等待,return -RT_EFULL;

    //消息队列已满
    while ((msg = mq->msg_queue_free) == RT_NULL){
        //挂起到suspend_sender_thread
        //开始线程自带的,超时时间为timeout的定时器
        //调用rt_schedule();让出CPU资源
        //如果超时,return thread->error;
    }

    //取出一个空闲消息块,mq->msg_queue_free = msg->next;
    //复制消息的内容,rt_memcpy(msg + 1, buffer, size);
    //消息放到队尾,mq->msg_queue_tail = msg;
    //消息数目加1,mq->entry ++;

    //如有接收等待的线程,唤醒
    if (!rt_list_isempty(&mq->parent.suspend_thread)){
        rt_ipc_list_resume(&(mq->parent.suspend_thread));
        rt_schedule();
    }
}

5、接收消息的过程

rt_err_t rt_mq_recv(rt_mq_t    mq,
                    void      *buffer,
                    rt_size_t  size,
                    rt_int32_t timeout)
{
    //如果消息队列为空,且timeout == 0,直接return -RT_ETIMEOUT;

    //消息队列为空
    while (mq->entry == 0){
        //挂起到mq->parent.suspend_thread
        //开启定时器
        //调用rt_schedule();让出CPU资源
        //如果超时,return thread->error;
    }

    //从队首msg_queue_head获取数据
    msg = (struct rt_mq_message *)mq->msg_queue_head;
    //队首后移
    mq->msg_queue_head = msg->next;
    //消息数目减1
    mq->entry --;
    //复制消息的内容到buffer
    rt_memcpy(buffer, msg + 1, size > mq->msg_size ? mq->msg_size : size);
    //该数据块挂到空闲队列上
    msg->next = (struct rt_mq_message *)mq->msg_queue_free;
    mq->msg_queue_free = msg;

    //如有发送等待的线程,唤醒
    if (!rt_list_isempty(&(mq->suspend_sender_thread))){
        rt_ipc_list_resume(&(mq->suspend_sender_thread));
        rt_schedule();
    }
}

  数据结构与算法 最新文章
【力扣106】 从中序与后续遍历序列构造二叉
leetcode 322 零钱兑换
哈希的应用:海量数据处理
动态规划|最短Hamilton路径
华为机试_HJ41 称砝码【中等】【menset】【
【C与数据结构】——寒假提高每日练习Day1
基础算法——堆排序
2023王道数据结构线性表--单链表课后习题部
LeetCode 之 反转链表的一部分
【题解】lintcode必刷50题<有效的括号序列
上一篇文章      下一篇文章      查看所有文章
加:2022-04-24 09:40:34  更:2022-04-24 09:44:18 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 8:52:22-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码