本文共 2264 字,大约阅读时间需要 7 分钟。
事件是信号量的扩展,在很多情况下可以用事件代替信号量的同步,事件可以一对一、一对多、多对一、多对多。
一个线程可等待多个事件的触发:可以是其中任意一个事件唤醒线程进行事件处理的操作;也可以是几个事件都到达后才唤醒线程进行后续的处理;同样,事件也可以是多个线程同步多个事件,这种多个事件的集合可以用一个32位无符号整型变量来表示,变量的每一位代表一个事件,线程通过“逻辑与”或“逻辑或”与一个或多个事件建立关联,形成一个事件集。事件的“逻辑或”也称为是独立型同步,指的是线程与任何事件之一发生同步;事件“逻辑与”也称为是关联型同步,指的是线程与若干事件都发生同步。RT-Thread定义的事件有以下特点:• 事件只与线程相关,事件间相互独立:每个线程拥有32个事件标志,采用一个32 bit无符号整型数进行记录,每一个bit代表一个事件。若干个事件构成一个事件集;• 事件仅用于同步,不提供数据传输功能;• 事件无排队性,即多次向线程发送同一事件(如果线程还未来得及读走),其效果等同于只发送一次。在RT-Thread实现中,每个线程都拥有一个事件信息标记,它有三个属性,分别是RT_EVENT_FLAG_AND(逻辑与),RT_EVENT_FLAG_OR(逻辑或)以及RT_EVENT_FLAG_CLEAR(清除标记)。当线程等待事件同步时,可以通过32个事件标志和这个事件信息标记来判断当前接收的事件是否满足同步条件。
IPC对象struct rt_event{ struct rt_ipc_object parent; /**< inherit from ipc_object */ rt_uint32_t set; /**< event set */};typedef struct rt_event *rt_event_t;set是一个32位无符号整数,事件是用位操作来进行通讯的,每一个 bit/位 代表一个信号rt_event_send(&event, (1 << 3)|(1 << 5)|(1 << 20));//一次发送3个信号rt_err_t rt_event_recv(rt_event_t event, rt_uint32_t set, //接收的bit尾 rt_uint8_t option,//接收到时间后进行的操作 rt_int32_t timeout, rt_uint32_t *recved)//纸箱收到的事件,比如收到(1 << 3)|(1 << 5),则为0x0010 1000 * flag defintions in event */#define RT_EVENT_FLAG_AND 0x01 /**< logic and */ 2个事件要同时接收到,即同时满足条件#define RT_EVENT_FLAG_OR 0x02 /**< logic or */2个事件接收到一个就行,即满足一个条件就可以#define RT_EVENT_FLAG_CLEAR 0x04 /**< clear flag */清除事件 if (rt_event_recv(&event, ((1 << 3) | (1 << 5)), RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR,//bit3 bit5都是1事件才成立,接收到之后清除bit RT_WAITING_FOREVER, &e) == RT_EOK)//永久等待,e是事件发送过程中的内存块,类似于消息队列,把发送方发送的内容复制到e中, { rt_kprintf("thread1: AND recv event 0x%x\n", e); }
API
rt_event_t rt_event_create (const char* name, rt_uint8_t flag);//创建rt_err_t rt_event_delete (rt_event_t event);//删除rt_err_t rt_event_init(rt_event_t event, const char* name, rt_uint8_t flag);//初始化rt_err_t rt_event_detach(rt_event_t event);//脱离rt_err_t rt_event_send(rt_event_t event, rt_uint32_t set);//发送rt_err_t rt_event_recv(rt_event_t event, rt_uint32_t set, rt_uint8_t option,rt_int32_t timeout, rt_uint32_t* recved);//接收
转载地址:http://fswsi.baihongyu.com/