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

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;
}

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); // 开中断
}