10 事件集：为什么发送事件的时候也需要清空标志位，而不是全部都在接受处理后清空

发布于 2021-11-22 10:01:09 浏览：1424 订阅该版

**RT-thread 标准版 3.1.5**

目前有个想法，通过使用事件集来表示一组命令，判断逻辑如下所示：
```c
if (rt_event_recv(event, 0xFFFFFFFF,
        RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
        RT_WAITING_FOREVER, &e) == RT_EOK)
{
    /* 对接受到事件轮询处理 */
    while (e)
    {
        /* 获取第一个为1 bit的位置 */
        rt_uint8_t fisrtBit = __rt_ffs(e) - 1;
        rt_kprintf("%s receive %d\n", event->parent.parent.name, fisrtBit);
        /* 清除对应标志位 */
        e &= ~(1ul << fisrtBit);
    }
}
```
但是此时有个问题，如果在短时间内多次发送同一命令（接受处理线程优先级较低，全部发送完后才会进行调度），例如：
```
rt_event_send(event, 1 << 0);
rt_event_send(event, 1 << 0);
rt_event_send(event, 1 << 0);
rt_event_send(event, 1 << 0);
```
则此时接受函数这边会处理两次，打印结果如下所示
```
cmd0 receive 0
cmd0 receive 0
```
通过分析源代码，原因是：首次发送的时候进行了标志位的清空，但是由于接受处理线程的优先级较低，此时不会产生调度，当再次调用rt_event_send，此时不满足条件，不会清空标志位。当全部发送完成后，此时产生系统调度，执行rt_event_recv中rt_schedule()后续代码，但是由于对应标志位还是置1，因此还会再接受一次，最终输出两次打印结果。以下为rt_event_send与rt_event_recv部分代码以及一些自己注释
```c
/* rt_event_send 部分处理代码 */
/* condition is satisfied, resume thread */
if (!rt_list_isempty(&event->parent.suspend_thread))
    {
        /* search thread list to resume thread */
        n = event->parent.suspend_thread.next;
        while (n != &(event->parent.suspend_thread))
        {
            /* get thread */
            thread = rt_list_entry(n, struct rt_thread, tlist);

status = -RT_ERROR;
            if (thread->event_info & RT_EVENT_FLAG_AND)
            {
                if ((thread->event_set & event->set) == thread->event_set)
                {
                    /* received an AND event */
                    status = RT_EOK;
                }
            }
            else if (thread->event_info & RT_EVENT_FLAG_OR)
            {
                if (thread->event_set & event->set)
                {
                    /* save the received event set */
                    thread->event_set = thread->event_set & event->set;

/* received an OR event */
                    status = RT_EOK;
                }
            }
            else
            {
                /* enable interrupt */
                rt_hw_interrupt_enable(level);

return -RT_EINVAL;
            }

/* move node to the next */
            n = n->next;

/* condition is satisfied, resume thread */
            if (status == RT_EOK)
            {
                /* 为什么在发送的时候清空? */
                /* clear event */
                if (thread->event_info & RT_EVENT_FLAG_CLEAR)
                    event->set &= ~thread->event_set;

/* resume thread, and thread list breaks out */
                rt_thread_resume(thread);

/* need do a scheduling */
                need_schedule = RT_TRUE;
            }
        }
    }
```
```
/* rt_event_recv 部分处理代码 */
/* do a schedule */
rt_schedule();

if (thread->error != RT_EOK)
{
    /* return error */
    return thread->error;
}

/* 为什么不在这里再清空标志位 */
/*if (xxx)
    clear flag;
*/

/* received an event, disable interrupt to protect */
level = rt_hw_interrupt_disable();

/* set received event */
if (recved)
    *recved = thread->event_set;
```
疑问：为什么要在发送的时候清空标志位，而不是统一在接受的时候再清空，麻烦各位大佬解答一下，谢谢。
PS: 若有其它意见或问题，也请提出，一起探讨，- 。-。