rt_wqueue_wakeup每执行一次只能唤醒等待队列中的一个线程？

发布于 2022-10-19 14:30:36 浏览：559 订阅该版

2 个回答

张世争 2022-10-20

学以致用

LeonRT 2022-10-20

hello

张世争 2022-10-20

学以致用

LeonRT 2022-10-20

hello

张世争 2022-10-20

学以致用

请登录后再发布评论，点击登录

追加回复

sync 2024-08-21

这家伙很懒，什么也没写！

rt_wqueue_wakeup每执行一次只能唤醒等待队列中的一个线程
关键在于函数rt_wqueue_wakeup内部
```C
    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)
            {
                rt_thread_resume(entry->polling_thread);
                need_schedule = 1;

rt_wqueue_remove(entry);
                break;
            }
        }
    }
```
每次只找到一个线程就break退出了。

如果想唤醒所有的等待队列，需要修改为
```C
    if (!(rt_list_isempty(queue_list)))
    {
        rt_list_for_each_safe(node,n,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)
            {
                rt_thread_resume(entry->polling_thread);
                need_schedule = 1;

rt_wqueue_remove(entry);
//                break;
            }
        }
    }
```