completion使用问题

发布于 2023-03-26 10:32:05 浏览：692 订阅该版

请问下rt_completion_wait函数里面将线程加入挂起链表，
但是在rt_completion_done函数处理完没看到移除，
这样链表不会变得越来越长吗？

1 个回答

lchnu 2023-03-26

Witness, Understand, Skill

完成量不支持某个线程尚未唤醒的时候，其他线程调用wait。
把它看作单对单的轻量二值信号量是没有问题的。但是，多对一的情况是不适用的。

文档中心提到：
完成量不支持在某个线程中调用 rt_completion_wait，还未唤醒退出时，在另一个线程中调用该函数。

考虑如下场景：

完成量初始化，链表为空，flag为RT_UNCOMPLETED；
thread1等待完成量，flag为RT_UNCOMPLETED，满足wait函数的if条件，加入链表，挂起；
thread2等待完成量，flag依然为RT_UNCOMPLETED，满足wait函数的if条件，触发RT_ASSERT(rt_list_isempty(&(completion->suspended_list)))

所以，链表不会越来越长。

如下是一段测试代码，尝试把thread2_entry中的rt_completion_done和rt_completion_wait互斥屏蔽。

你会发现，thread2也在wait时，触发断言进入死循环了。thread2使用done时，是完成量的一般使用方式。

#include <rtthread.h>
#include <rtdevice.h>
#define DBG_TAG "main"
#define DBG_LVL DBG_LOG
#include <rtdbg.h>
static struct rt_completion completion;
void thread2_entry(void *arg)
{  
    while(1)
    {
        // rt_completion_done(&completion);
        rt_completion_wait(&completion, RT_WAITING_FOREVER);
        rt_thread_mdelay(1000);
    }
}
int main(void)
{
    rt_completion_init(&completion);
    rt_thread_t tid = rt_thread_create("thread2", thread2_entry,RT_NULL,1024,25,0);
    rt_thread_startup(tid);
    while (1)
    {
        rt_completion_wait(&completion, RT_WAITING_FOREVER);
        rt_kprintf("thread1: completion waitting done\n");
    }
    return RT_EOK;
}