[问答]

RT-Thread之等待队列的定义及使用方法简析

问答对人有帮助，内容完整，我也想知道答案 0 1. 等待队列是什么等待队列是一个轻量级的线程间异步通讯方式。他有两个特点：轻量： API 较少异步: 2. 等待队列怎么使用用户只需要使用其中的五个 API 就可以了。初始化等待队列 rt_inline void rt_wqueue_init(rt_wqueue_t queue) queue : 消息队列控制块加入等待队列 int rt_wqueue_wait(rt_wqueue_t queue, int condition, int msec) queue : 等待队列的控制块 condition ：这个形参没有使用到, 必须传递 0 msec : 需要等待的时间，单位是毫秒唤醒等待队列 void rt_wqueue_wakeup(rt_wqueue_t queue, void key) queue : 等待队列的控制块 key ：唤醒条件，目前源码中未使用在等待队列中插入一个节点 void rt_wqueue_add(rt_wqueue_t queue, struct rt_wqueue_node node) queue : 等待队列控制块 node : 插入队列的节点从等待队列移除一个节点 void rt_wqueue_remove(struct rt_wqueue_node node) node : 需要移除的节点 3. 等待队列的实现* 初始化等待队列 rt_inline void rt_wqueue_init(rt_wqueue_t queue) // 这里使用了关键字 inline { RT_ASSERT(queue != RT_NULL); // 断言检查 queue->flag = RT_WQ_FLAG_CLEAN; // 设置标志位 rt_list_init(&(queue->waiting_list)); // 初始化链表 } 加入等待队列 int rt_wqueue_wait(rt_wqueue_t queue, int condition, int msec) { int tick; rt_thread_t tid = rt_thread_self();// 获取当前调用等待队列的线程 rt_timer_t tmr = &(tid->thread_timer);// 获取当前线程的定时器 struct rt_wqueue_node __wait;// 等待队列的节点 rt_base_t level; /* current context checking / RT_DEBUG_NOT_IN_INTERRUPT; tick = rt_tick_from_millisecond(msec);// 获取传递进来的时间的转换成 tick，所以超时时间的单位是 ms if ((condition) \|\| (tick == 0)) // condition 必须传递 0 return 0; __wait.polling_thread = rt_thread_self(); //获取当前线程给到 __wait __wait.key = 0; // key 赋值 0 __wait.wakeup = __wqueue_default_wake; // 这个函数建议用户自己实现一个，默认的这个会返回0 rt_list_init(&__wait.list); // 初始化链表 level = rt_hw_interrupt_disable(); // 关中断 if (queue->flag == RT_WQ_FLAG_WAKEUP) // 如果队列已经是唤醒状态了 { / already wakeup / goto __exit_wakeup; } rt_wqueue_add(queue, &__wait); // 把 __wait 插入到 queue-> waiting_list 的前面 rt_thread_suspend(tid);// 挂起这个线程 / start timer / if (tick != RT_WAITING_FOREVER) // 启动线程的定时器 { rt_timer_control(tmr, RT_TIMER_CTRL_SET_TIME, &tick); rt_timer_start(tmr); } rt_hw_interrupt_enable(level);// 开中断 rt_schedule(); // 进行一次调度 level = rt_hw_interrupt_disable(); // 关中断 __exit_wakeup: queue->flag = 0; // 设置 FLAG ，这个用宏的方式可能更优雅 rt_hw_interrupt_enable(level); // 开中断 rt_wqueue_remove(&__wait); // 从等待队列中移除 __wait 这个节点 return 0; } 唤醒等待队列 void rt_wqueue_wakeup(rt_wqueue_t queue, void key) { rt_base_t level; register int need_schedule = 0; rt_list_t queue_list; struct rt_list_node node; struct rt_wqueue_node entry; queue_list = &(queue->waiting_list); level = rt_hw_interrupt_disable(); // 关中断 /* set wakeup flag in the queue / queue->flag = RT_WQ_FLAG_WAKEUP; // 设置等待队列的标志位 if (!(rt_list_isempty(queue_list))) // 检查链表是否为空 { for (node = queue_list->next; node != queue_list; node = node->next)// 循环遍历 { entry = rt_list_entry(node, struct rt_wqueue_node, list);// 获取等待队列控制块 if (entry->wakeup(entry, key) == 0) // wakeup 一定会返回 0 { rt_thread_resume(entry->polling_thread);// 恢复这个线程 need_schedule = 1; //需要调度设置为 1 rt_wqueue_remove(entry); // 从等待队列的链表中移除这个等待队列 break;// 跳出循环遍历 } } } rt_hw_interrupt_enable(level); // 开启中断 if (need_schedule) rt_schedule();// 开启调度 } 默认唤醒函数 int __wqueue_default_wake(struct rt_wqueue_node wait, void key) { return 0; } 这里未作任何的操作就进行了返回 0 ，这里做的太简单粗暴了。等待队列插入一个节点 void rt_wqueue_add(rt_wqueue_t queue, struct rt_wqueue_node node) { rt_base_t level; level = rt_hw_interrupt_disable();// 关中断 rt_list_insert_before(&(queue->waiting_list), &(node->list));// 把 node->list 插入到 queue->waiting_list rt_hw_interrupt_enable(level); // 开中断 } 等待队列移除一个节点 void rt_wqueue_remove(struct rt_wqueue_node node) { rt_base_t level; level = rt_hw_interrupt_disable(); //关中断 rt_list_remove(&(node->list)); // 移除节点 node rt_hw_interrupt_enable(level); // 开中断 } 4. 总结等待队列的使用了关键字 rt_inline 。在 rt_device 注册设备时候都使用了 rt_wqueue_init ，这里有一个 C 语言的小技巧，可以自己去搜索 inline 来学习一下。进入等待队列的形参 condition 必须传递 0, 超时时间的单位是 ms 唤醒等待队列的条件 key，并未实现。如果有需要使用到等待队列的场景不要擅自修改源码，因为 RTT 设备框架大量使用了，擅自修改会导致报错，自己可以参考官方的实现重造一个函数，去实现对 key 等待队列的源码位于/rt_thread_master/components/drivers/src/waitqueue.c 用户可以自行创建一个 API 来实现自定义的 wake_up 0
2022-4-11 10:40:43　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × ss 该类别下有 100 个回答。邀请回答 chunhuahua 该类别下有 55 个回答。邀请回答而无返还该类别下有 47 个回答。邀请回答王尚岱该类别下有 45 个回答。邀请回答最强海贼王该类别下有 45 个回答。邀请回答河神大人该类别下有 43 个回答。邀请回答万航渡路该类别下有 40 个回答。邀请回答 nhcp 该类别下有 40 个回答。邀请回答 wonick 该类别下有 39 个回答。邀请回答青sky 该类别下有 38 个回答。邀请回答 mintsy 该类别下有 38 个回答。邀请回答熊本熊该类别下有 37 个回答。邀请回答其实znvm 该类别下有 36 个回答。邀请回答 zhongnian 该类别下有 36 个回答。邀请回答 h1654155272.9717 该类别下有 36 个回答。邀请回答小野七七该类别下有 35 个回答。邀请回答糖栗子该类别下有 35 个回答。邀请回答 juju宇哥该类别下有 34 个回答。邀请回答星星公交站该类别下有 33 个回答。邀请回答梅利号该类别下有 33 个回答。邀请回答举报王银喜相关推荐 • RT-Thread系统消息队列常用的函数接口有哪些 2399 • RT-Thread文件系统的基本知识和使用方法 3824 • 从μCOS-Ⅱ到RT-Threadの移植方法是什么 1377 • rt-thread邮箱-队列区别是什么？ 374 • 如何更好地使用RT-Thread AT组件？ 3240 • RT-Thread系统的信号如何进行管理和使用呢 2748 • 学习RT-THREAD有什么方法 3301 • RT-Thread学习笔记和finsh shell配置方法 5457 • RT-Thread操作系统有哪些优势？ 2333 • RT-Thread入门之如何建立工程 stm32f103c8+hal库 985