RT-Thread-个人分享心得（六）——线程间同步（事件集）RT-Thread问答社区

个人分享心得（六）——线程间同步（事件集）

发布于 2019-03-30 19:28:42 浏览：2323 订阅该版

[tocm]

# 事件集

事件集 `event`：与信号量的本质区别就是能够多事件触发，其结构体如下所示：

```c
struct rt_event
{
    struct rt_ipc_object parent;

rt_uint32_t          set;
};
```

由上述的事件集结构体可以发现与信号量的结构体相似，直观的区别就是信号量的 `value` 的数据类型是 `rt_uint16_t`，而事件集的 `set` 的数据类型是 `rt_uint32_t`。但是事件中的设定值是32位，每一位标志着一个事件，通过对指定的位进行置1表示触发指定的事件，而对于各个线程可以设定不同的事件集来触发。对于不同的事件之间可以设置逻辑与 `RT_EVENT_FLAG_AND`、逻辑或 `RT_EVENT_FLAG_OR`，这两个逻辑也可与清除标志 `RT_EVENT_FLAG_CLEAR` 进行 `|`操作来清除重置事件标志位。

但是对于在接收单个事件时设置 `RT_EVENT_FLAG_AND` 和 `RT_EVENT_FLAG_OR` 效果一样，其原因可以看 `rt_event_recv` 的如下源码：

```c
    /* check event set */
    if (option & RT_EVENT_FLAG_AND)
    {
        if ((event->set & set) == set)
            status = RT_EOK;
    }
    else if (option & RT_EVENT_FLAG_OR)
    {
        if (event->set & set)
            status = RT_EOK;
    }
    else
    {
        /* either RT_EVENT_FLAG_AND or RT_EVENT_FLAG_OR should be set */
        RT_ASSERT(0);
    }
```

当接收到单个事件时，若设置了逻辑与则接收设置的事件标志位 `event->set` 与接收到的 `set` 一致，那么经过 `&` 操作后依然还是初值，即为真 `RT_EOK`；若设置了逻辑或则与上述同理，输出状态依旧为真 `RT_EOK`。
而当接收多个事件时，若设置的状态位为逻辑与 `RT_EVENT_FLAG_AND` 那么为真的条件为接收的事件标志位与设定的事件标志位完全一致，而设置的状态位为逻辑或 `RT_EVENT_FLAG_OR`，接收的事件标志位与设定的事件标志位只要没有完全不一样，那么通过 `&` 的结果就不为假。
但是不管接收单事件还是多事件，如果只设置了 `RT_EVENT_FLAG_CLEAR` 没有设置逻辑与 `RT_EVENT_FLAG_AND` 或者逻辑或 `RT_EVENT_FLAG_OR`，那么将会调用 `RT_ASSERT(0);`，直接终止程序。

但是如果在接收是设置了 `RT_EVENT_FLAG_AND` | `RT_EVENT_FLAG_OR`，则相当于设置了 `RT_EVENT_FLAG_AND`。根据以下宏定义：

```c
#define RT_EVENT_FLAG_AND               0x01
#define RT_EVENT_FLAG_OR                0x02
#define RT_EVENT_FLAG_CLEAR             0x04
```

那么 `RT_EVENT_FLAG_AND | RT_EVENT_FLAG_OR` 的结果为0x03，通过判断 `option & RT_EVENT_FLAG_AND` 依旧为真，则相当于设置了 `RT_EVENT_FLAG_AND`。

##### ！！！注意在向事件对象发送信息的时候，禁止发送的事件集为0！！！

当然在中断例程中也可以实现发送事件，但是若在中断中运行发送事件，即使中断中有延时线程无法抢占中断。首先创建硬件定时器 `timer1` 和接收线程 `thread1`，然后在中断中分别发送事件3和事件5，接受线程分别接收事件3和事件5，判断其执行顺序。部分代码如下：
```c
event = rt_event_create("event", RT_IPC_FLAG_FIFO);
timer1 = rt_timer_create("timer", timer_handler, RT_NULL, 10, RT_TIMER_FLAG_ONE_SHOT | RT_TIMER_FLAG_HARD_TIMER);
thread1 = rt_thread_create("event thread", event_thread1, RT_NULL, 1024, 15, 10);

static void event_thread1(void *paramter)
{
 rt_uint32_t e;
 
 rt_kprintf("start run thread1. ");
 if (rt_event_recv(event, (event_flag3),
 RT_EVENT_FLAG_AND,
 RT_WAITING_FOREVER, &e) == RT_EOK)
 {
 rt_kprintf("thread1: receive event_flag3. ");
 }
 else
 {
 rt_kprintf("thread1 don't receive event_flag3. ");
 }
 
 if (rt_event_recv(event, (event_flag5),
 RT_EVENT_FLAG_AND,
 RT_WAITING_FOREVER, &e) == RT_EOK)
 {
 rt_kprintf("thread1: receive event_flag5. ");
 }
 else
 {
 rt_kprintf("thread1 don't receive event_flag5. ");
 }
 rt_kprintf("run thread1 end. ");
}

static void timer_handler(void *parameter)
{
 rt_kprintf("timer1: send event3 ");
 rt_event_send(event, event_flag3);
 rt_kprintf("timer1: send event5 ");
 rt_event_send(event, event_flag5);
 rt_kprintf("timer end. ");
}
```

输出结果为：

```
 \ | /
- RT -     Thread Operating System
 / | \     3.1.0 build Mar 30 2019
 2006 - 2018 Copyright by rt-thread team
msh >test_sample
start run thread1.
msh >timer1: send event3
timer1: send event5
timer end.
thread1: receive event_flag3.
thread1: receive event_flag5.
run thread1 end.
```

##### ！！！中断例程函数中禁止加入延时，譬如 `rt_thead_delay` 函数。第一中断没有线程环境，没有睡眠模式；第二中断以精简为主，降低CPU使用效率。
如果在中断函数中首先发送事件3 `event_flag3`，在发送事件5 `event_flag5`，那么接收线程将无法接收到事件3，具体原因未知，也希望各方大佬能帮小弟解读。:-)

中断例程中最好不要进行接收事件操作，如果进行了该操作，则会产生如下报错：

```
Function[rt_event_recv] shall not be used in ISR
(0) assertion failed at function:rt_event_recv, line number:1147 
```
##### 综上所述：线程既可以发送事件和接收事件，而中断只能发送事件无法接收事件