嵌入式系统开发-Chapter6-同步、互斥与通信.ppt

《嵌入式系统开发-Chapter6-同步、互斥与通信.ppt》由会员分享，可在线阅读，更多相关《嵌入式系统开发-Chapter6-同步、互斥与通信.ppt（126页珍藏版）》请在三一办公上搜索。

1、第五章 同步、互斥与通信,主要内容,1 概述2 信号量3 邮箱和消息队列4 事件5 异步信号6 管道,第一节概述,多任务系统中任务之间的关系相互独立：仅竞争CPU资源。竞争除CPU外的其他资源(互斥)。同步：协调彼此运行的步调，保证协同运行的各个任务具有正确的执行次序。通信：彼此间传递数据或信息，以协同完成某项工作。,任务与中断处理程序或其他任务进行同步或通信：单向同步或通信：一个任务与另一个任务或一个ISR同步或通信。双向同步或通信：两个任务相互同步或通信。双向同步不能在任务与ISR之间进行，因为ISR不能等待。,ISR x,Task y,POST,PEND,任务与ISR之间的同步(单向),

2、Task x,Task y,POST,PEND,POST,PEND,任务与任务之间的同步(双向),任务与任务之间的同步(单向),Task x,Task y,POST,PEND,任务间的耦合程度：耦合程度较高任务之间需要进行大量的通信，相应的系统开销较大；耦合程度较低任务之间不存在通信需求，其间的同步关系很弱甚至不需要同步或互斥，系统开销较小。研究任务间耦合程度的高低对于合理地设计应用系统、划分任务有很重要的作用。,在单处理器平台上，嵌入式操作系统内核提供的同步、互斥与通信机制主要包括：信号量(semaphore)，用于互斥与同步。事件(组)(event group)，用于同步。异步信号(asy

3、nchronous signal)，用于同步。邮箱(mailbox)、消息队列(message queue)，用于消息通信。管道(pipe)，提供非结构化数据交换和实现同步。,以下一些机制也可用于同步与通信(在单处理器或多处理器系统中)：全局变量。共享内存。Sockets。远程过程调用(Remote Procedure Call)。,第二节信号量,1 信号量的种类及用途2 互斥信号量3 二值信号量4 计数信号量5 信号量机制的主要数据结构6 典型的信号量操作,信号量用于实现任务与任务之间、任务与中断处理程序之间的同步与互斥。信号量一般分为三种：,1 信号量的种类及用途,用于解决互斥问题。可能会

4、引起优先级反转问题。,用于解决同步问题。,用于解决资源计数问题。,互斥信号量,计数信号量,二值信号量,用互斥信号量保护的代码区称作“临界区”。临界区代码通常用于对共享资源的访问。获得互斥信号量的任务进入“临界区”，其他试图获取信号量的任务就会被阻塞。当任务离开临界区时，就是释放信号量。互斥信号量的值被初始化成1，表明目前没有任务进入“临界区”，但最多只有一个任务可以进入“临界区”。,2 互斥信号量,13,INT8U OSTaskCreate(void(*task)(void*pd),void*pdata,OS_STK*ptos,INT8U prio)OS_STK*psp;INT8U err;O

5、S_ENTER_CRITICAL();if(OSTCBPrioTblprio=(OS_TCB*)0)/*Make sure task doesnt already exist at this priority*/OSTCBPrioTblprio=(OS_TCB*)1;/*Reserve the priority to prevent others from doing the same thing until task is created.*/OS_EXIT_CRITICAL();psp=(OS_STK*)OSTaskStkInit(task,pdata,ptos,0);/*Initiali

6、ze the tasks stack*/err=OS_TCBInit(prio,psp,(OS_STK*)0,0,0,(void*)0,0);if(err=OS_NO_ERR)OS_ENTER_CRITICAL();OSTaskCtr+;/*Increment the#tasks counter*/OS_EXIT_CRITICAL();if(OSRunning=TRUE)/*Find highest priority task if multitasking has started*/OS_Sched();else OS_ENTER_CRITICAL();OSTCBPrioTblprio=(O

7、S_TCB*)0;/*Make this priority available to others*/OS_EXIT_CRITICAL();return(err);OS_EXIT_CRITICAL();return(OS_PRIO_EXIST);,OSTaskCreate in ucOS,共享资源：一段存储器空间、一个数据结构或I/O设备，也可能是被两个或多个并发任务共享的任何内容。使用互斥信号量可以实现对共享资源的串行访问。,互斥信号量状态图,开启,锁定,初始化值为1,申请并获得值为0,释放值为1,申请(递归)并获得锁定数加1,释放(递归)锁定数减1,所有权当一个任务通过获取互斥信号量而将其

8、锁定时，得到该互斥信号量的所有权。当一个任务释放信号量时，失去对其的所有权。申请与释放要匹配：任务要释放互斥信号量，必须事前先获取该信号量。,16,INT8U OSTaskCreate(void(*task)(void*pd),void*pdata,OS_STK*ptos,INT8U prio)OS_STK*psp;INT8U err;OS_ENTER_CRITICAL();if(OSTCBPrioTblprio=(OS_TCB*)0)/*Make sure task doesnt already exist at this priority*/OSTCBPrioTblprio=(OS_TCB

9、*)1;/*Reserve the priority to prevent others from doing the same thing until task is created.*/OS_EXIT_CRITICAL();psp=(OS_STK*)OSTaskStkInit(task,pdata,ptos,0);/*Initialize the tasks stack*/err=OS_TCBInit(prio,psp,(OS_STK*)0,0,0,(void*)0,0);if(err=OS_NO_ERR)OS_ENTER_CRITICAL();OSTaskCtr+;/*Increment

10、 the#tasks counter*/OS_EXIT_CRITICAL();if(OSRunning=TRUE)/*Find highest priority task if multitasking has started*/OS_Sched();else OS_ENTER_CRITICAL();OSTCBPrioTblprio=(OS_TCB*)0;/*Make this priority available to others*/OS_EXIT_CRITICAL();return(err);OS_EXIT_CRITICAL();return(OS_PRIO_EXIST);,OSTask

11、Create in ucOS,Task1,RoutineA,RoutineB,嵌套资源访问如果Task1调用RoutineA，而RoutineA又调用RoutineB，并且三者访问相同的共享资源，就发生了递归共享资源的访问同步问题。,一个递归的互斥信号量允许嵌套锁定互斥信号量，而不引起死锁。,每个获取信号量的调用必须与释放信号量的调用相匹配。当最外层的获取信号量的调用与释放信号量的调用匹配时，该信号量才允许被其它任务访问。用于同步的信号量不支持嵌套访问。删除安全需要保护在临界区执行的任务不会被意外地删除。删除一个在临界区执行的任务可能引起意想不到的后果，造成保护资源的信号量不可用，可能导致资源

12、处于破坏状态。,各种互斥机制比较,3 二值信号量,用于任务与任务之间、任务与中断服务程序之间的同步用于同步的二值信号量初始值为0，表示同步事件尚未产生；任务申请信号量以等待该同步事件的发生；另一个任务或ISR到达同步点时，释放信号量(将其值设置为1)表示同步事件已发生，以唤醒等待的任务。,二值信号量状态图,可获得,不可获得,申请并获得(值为0),释放(值为1),初始化值为0,Task1()执行一些操作;将信号量sem1置1;申请信号量sem2;,Task2()申请信号量sem1;执行一些操作;将信号量sem2置1;,Task2申请信号量sem1失败，系统切换到Task1,sem1被置1后，Ta

13、sk2得到sem1并抢占Task1,Task2运行到某处时因某种原因被阻塞，系统切换到Task1,用二值信号量实现两个任务之间的双向同步Task2优先级高于Task1sem1和sem2的初始值均为0,4 计数信号量,用于控制系统中共享资源的多个实例的使用，允许多个任务同时访问同一种资源的多个实例。计数信号量被初始化为n(非负整数)，n为该种共享资源的数目。,计数信号量状态图,可获得,不可获得,初始化值大于0,申请并获得值为0,释放值为1,申请并获得值减1,释放值加1,计数信号量使用实例：有界缓冲问题,生产者任务do 产生一个数据项 申请empty 申请mutex 将新生成的数据项添加到缓冲中

14、释放mutex 释放full while(1);,消费者任务do 申请full 申请mutex 从缓冲中移出一个数据项的内容 释放mutex 释放empty 消费新获得的数据项内容 while(1);,计数信号量full：已被填充的数据项数目，取值范围0n，初始值为0计数信号量empty：空闲数据项数目，取值范围为0n，初始值为n；互斥信号量mutex：控制生产者任务和消费者任务对有界缓冲的访问，初始值为1。,5 信号量机制的主要数据结构,信号量控制块：管理所有创建的信号量，内核在系统运行时动态分配和回收信号量控制块。互斥和二值信号量控制块结构:Binary_Semaphore_Control

15、_Block,wait_queue任务等待队列attributes信号量属性lock_nesting_behavior试图嵌套获得时的规则 wait_discipline 任务等待信号量的方式priority_ceiling 优先级天花板值lock是否被占有holder拥有者 nest_count嵌套层数,计数信号量控制结构Counting_Semaphore_Control_Block wait_queue任务等待队列 attributes计数信号量属性 maximum_count最大计数值 wait_discipline任务等待信号量的方式 count当前计数值,信号量内部实现机制实例说明

16、C/OS-II,事件控制块ECB同步与通信机制的基本数据结构typedef structINT8UOSEventType;/事件类型INT16UOSEventCnt;/计数器(信号量)void*OSEventPtr;/指向消息或消息队列的指针INT8UOSEventGrp;/等待任务所在的事件组INT8UOSEventTblOS_EVENT_TBL_SIZE;/等待任务的事件表OS_EVENT;/等待事件的任务中，优先级最高的任务获得事件。,当一个事件发生后，等待事件列表中优先级最高的任务(即在.OSEventTbl&OSEventGrp中所有被置1的位中优先级数值最小的任务)得到该事件。,当

17、.OSEventTbln中的任何一位为1时，OSEventGrp中的第n位为1。与任务就绪列表类似！,将一个任务插入到等待事件的任务列表中：pevent-OSEventGrp|=OSMapTblprio 3;pevent-OSEventTblprio 3|=OSMapTblprio 与将一个任务插入到就绪列表中的操作类似！,Index Bit mask(Binary)0 0 0 0 0 0 0 0 11 0 0 0 0 0 0 1 02 0 0 0 0 0 1 0 03 0 0 0 0 1 0 0 04 0 0 0 1 0 0 0 05 0 0 1 0 0 0 0 06 0 1 0 0 0 0

18、 0 07 1 0 0 0 0 0 0 0,从等待事件的任务列表中使任务脱离等待状态if(pevent-OSEventTblprio 3 与将任务从就绪列表中清除的操作类似！,在等待事件的任务列表中查找优先级最高的任务y=OSUnMapTblpevent-OSEventGrp;x=OSUnMapTblpevent-OSEventTbly;prio=(y 3)+x;与查找优先级最高的就绪任务的操作类似！,空闲事件控制块链表,typedef structINT8UOSEventType;/事件类型INT16UOSEventCnt;/计数器(信号量)void*OSEventPtr;/指向消息或消息队

19、列的指针INT8UOSEventGrp;/等待任务所在的事件组INT8UOSEventTblOS_EVENT_TBL_SIZE;/等待任务的事件表OS_EVENT;/等待事件的任务中，优先级最高的任务获得事件。,6 典型的信号量操作,创建信号量获取（申请）信号量释放信号量删除信号量清除信号量的任务等待列表 获取有关信号量的各种信息,6.1 创建信号量,功能：根据应用传递的参数创建一个信号量。参数：信号量的名字、属性和初始值等。内核动作：从空闲信号量控制块链中分配一个信号量控制块，并初始化信号量属性。创建成功时，为其分配唯一的ID号返回给应用。如果已创建信号量数量已达到用户配置的最大数量，就返回

20、错误。,信号量的属性包括：类型。任务等待信号量的方式(即排列的顺序)。互斥信号量：与任务删除安全、递归访问以及解决优先级反转的策略相关的参数。,信号量的属性,信号量的类型,互斥信号量（MUTEX_SEMAPHORE）,计数信号量（COUNTING_SEMAPHORE）,二值信号量（BINARY_SEMAPHORE）,任务等待信号量的方式,先进先出（FIFO）顺序,优先级（PRIORITY）顺序,优先级反转问题的解决方法（只适用于互斥信号量）,优先级继承算法（INHERIT_PRIORITY）,优先级天花板算法(PRIORITY_CEILING)，需给出所有可能获得此信号量的任务中优先级最高的任

21、务的优先级。,OS_EVENT*OSSemCreate(INT16U cnt)OS_EVENT*pevent;pevent=OSEventFreeList;/从空闲事件控制块链中取得一个ECBif(OSEventFreeList!=(OS_EVENT*)0)OSEventFreeList=(OS_EVENT*)OSEventFreeList-OSEventPtr;if(pevent!=(OS_EVENT*)0)/初始化ECB的各个域pevent-OSEventType=OS_EVENT_TYPE_SEM;/事件类型为信号量pevent-OSEventCnt=cnt;/信号量的初始计数值peve

22、nt-OSEventPtr=(void*)0;OS_EventWaitListInit(pevent);/初始化等待任务列表return(pevent);/调用者需检查返回值，如果为NULL则表示建立失败,6.2 获取(申请)信号量,功能：试图获得应用指定的信号量。if 信号量的值大于0then 将信号量的值减1else 根据接收信号量的选项，将任务放到等待队列中，或是直接返回,当所申请的信号量不能被立即获得时，可以有以下几种选择：永远等待。不等待，立即返回，并返回一个错误状态码。指定等待时限(可有效避免死锁)。注意：不允许在ISR中选择等待。当任务选择等待时，将被按FIFO或优先级顺序放置在

23、等待队列中。,44,t0,t0,t1,t2,t3,t4,t5,t6,t7,t8,Critical section guarded by S,time,1,2,t9,t0,t10,t11,t12,t13,t14,t15,t16,t18,t17,假定在时间t1，任务T2获得信号量S2，进入临界区。在时间t3，任务T2又试图获得信号量S1，但一个高优先级任务T1在这个时候就绪，抢占任务T2并获得信号量S1，接下来任务T1又试图获得信号量S2。这样就出现了死锁现象。,如果任务等待一个使用优先级继承算法的互斥信号量，且它的优先级高于当前正占有此信号量的任务的优先级，那么占有信号量的任务将继承这个被阻塞的

24、任务的优先级。如果任务成功地获得一个采用优先级天花板算法的互斥信号量，它的优先级又低于优先级天花板，那么它的优先级将被抬升至天花板。,void OSSemPend(OS_EVENT*pevent,INT16U timeout,INT8U*err)if(pevent-OSEventCnt 0)/信号量值大于0，成功获得信号量并返回pevent-OSEventCnt-;*err=OS_NO_ERR;return;OSTCBCur-OSTCBStat|=OS_STAT_SEM;/设置任务状态为等待信号量OSTCBCur-OSTCBDly=timeout;/设置等待时限OS_EventTaskWait

25、(pevent);/将任务放置到信号量的等待列表中 OS_Sched();/内核实施任务调度，系统切换到另一就绪任务执行if(OSTCBCur-OSTCBStat/任务由于获得信号量而恢复执行，本调用成功返回,获取(等待)信号量,INT16U OSSemAccept(OS_EVENT*pevent)INT16U cnt;cnt=pevent-OSEventCnt;if(cnt 0)pevent-OSEventCnt-;return(cnt);,注意：即使不能成功获得信号量(返回值为0)，调用者也不会被阻塞。此函数可以在中断处理程序中使用。,获取(无等待地请求)信号量,6.3 释放信号量,功能：

26、释放一个应用指定的信号量。if 没有任务等待这个信号量then 信号量的值加1 else 将信号量分配给一个等待任务(将相应的任务移出等待队列，使其就绪)如果使用了优先级继承或优先级天花板算法：执行该功能(系统调用)的任务的优先级将恢复到原来的优先级。,INT8U OSSemPost(OS_EVENT*pevent)if(pevent-OSEventGrp!=0 x00)/如果有任务在等待该信号量OS_EventTaskRdy(pevent,(void*)0,OS_STAT_SEM);/使等待任务列表中优先级最高的任务就绪OS_Sched();/内核实施任务调度return(OS_NO_ERR

27、);/成功返回 if(pevent-OSEventCnt OSEventCnt+;/信号量的值加1return(OS_NO_ERR);/成功返回 return(OS_SEM_OVF);/信号量溢出,6.4 删除信号量,功能：从系统中删除应用指定的一个信号量。内核动作：将信号量控制块返还给系统。删除信号量的不一定是创建信号量的任务。如果有任务正在等待获得该信号量：执行此功能将使所有等待这个信号量的任务回到就绪队列中。,企图获取已删除的信号量将返回一个错误；互斥信号量：正被使用时(已经被某任务获取)，不能删除它。因为该信号量正在保护一个共享资源或临界代码段，该动作可能造成数据崩溃或其他严重问题。,

28、OS_EVENT*OSSemDel(OS_EVENT*pevent,INT8U opt,INT8U*err)BOOLEAN tasks_waiting;if(pevent-OSEventGrp!=0 x00/根据是否有任务在等待信号量设置等待标志tasks_waiting=TRUE;elsetasks_waiting=FALSE;switch(opt)case OS_DEL_NO_PEND:/如果有任务等待信号量则不删除信号量if(task_waiting=FALSE/没有任务等待，释放ECB回空闲链pevent-OSEventType=OS_EVENT_TYPE_UNUSED;pevent-

29、OSEventPtr=OSEventFreeList;OSEventFreeList=pevent;/调整空闲ECB链头指针*err=OS_NO_ERR;return(OS_EVENT)0);else*err=OS_ERR_TASK_WAITING;/有任务等待，删除信号量失败return(pevent);,case OS_DEL_ALWAYS:/无论有无任务等待都删除信号量/将等待列表中的每个任务都设置成就绪while(pevent-OSEventGrp!=0 x00)OS_EventTaskRdy(pevent,(void*)0,OS_STAT_SEM);/释放该信号量的ECB回空闲控制块

30、链pevent-OSEventType=OS_EVENT_TYPE_UNUSED;pevent-OSEventPtr=OSEventFreeList;OSEventFreeList=pevent;/如果之前有任务等待信号量，内核实施任务调度if(tasks_waiting=TRUE)OS_Sched();*err=OS_NO_ERR;return(OS_EVENT*)0);default:*err=OS_ERR_INVALID_OPT;return(pevent);,第三节邮箱和消息队列,1 通信方式概述2 消息队列机制的主要数据结构3 典型的消息队列操作4 消息队列的其他典型使用,任务间的通

31、信方式直接通信。在通信过程中双方必须明确地知道（命名）彼此：send(P，message)发送一个消息到任务P。receive(Q，message)从任务Q接收一个消息。间接通信。通信双方不需要指出消息的来源或去向，而通过中间机制来通信。如：send(A，message)发送一个消息给邮箱A。receive(A，message)从邮箱A接收一个消息。,1 通信方式概述,消息队列：属于间接通信方式。消息：内存空间中一段长度可变的缓冲区，其长度和内容均可以由用户定义。对消息内容的解释由应用完成。从操作系统观点看，消息没有定义的格式，所有的消息都是字节流，没有特定的含义。从应用观点看，根据应用定义的

32、消息格式，消息被解释成特定的含义。应用可以只把消息当成一个标志，这时消息机制用于实现同步。,一些操作系统内核把消息进一步分为：邮箱：仅能存放单条消息，它提供了一种低开销的机制来传送信息。每个邮箱可以保存一条大小为若干个字节的消息。消息队列：可存放若干消息，提供了一种任务间缓冲通信的方法。消息机制可支持定长与可变长度两种模式的消息可变长度的消息队列需要对队列中的每一条消息增加额外的存储开销。,2 消息队列机制的主要数据结构,消息队列及其相关的参数和支持数据结构,2.1 消息队列状态图,非空,满,队列创建消息数为0,消息队列状态图,消息发送消息数加1,空,消息发送消息数为1,消息接收消息数为0,消

33、息接收消息数减1,消息接收消息数减1,消息发送消息数等于队列长度,2.2 消息队列机制的主要数据结构,消息队列控制块管理所有创建的消息队列，系统运行时动态分配和回收消息队列控制块消息队列缓冲区存放发送到该队列的消息，接收者从缓冲区中取出消息。消息的发送或接收有两种方法：将数据从发送任务的空间完全拷贝到接收任务的空间中(效率较低，执行时间与消息大小有关)。只传递指向数据存储空间的指针(提高系统性能)。,发送和接收消息的消息拷贝和内存使用这种消息传递方法效率低、占用空间大一种效率更高的方式是传递消息指针,number_of_message,max_message_count,消息队列控制块,消息队

34、列缓冲区,消息队列的环形缓冲,max_message_count,queue_end,queue_start,queue_out,number_of_message,queue_in,消息指针,3 典型的消息队列操作,创建消息队列发送普通消息发送紧急消息发送广播消息接收消息删除消息队列获取有关消息队列的各种信息,3.1 创建消息队列,创建消息队列时，调用者可以指定如下参数：消息的最大长度。每个消息队列中最多的消息数。消息队列的属性。任务等待消息时的排队方式：FIFO或PRIORITY系统为新创建的消息队列分配唯一的ID。,3.2 发送消息,根据紧急程度的不同，消息通常可分为普通消息与紧急消息。

35、如果有任务正在等待消息(即消息队列为空)，则普通消息发送和紧急消息发送的执行效果是一样的。任务从等待队列移到就绪队列中，消息被拷贝到任务提供的缓冲区中。如果没有任务等待：发送普通消息将消息放在队列尾发送紧急消息将消息放在队列头,如果发送消息时队列已被填满，则不同的操作系统可能采取不同的处理办法：挂起试图向已满的消息队列中发送消息的任务(不适用于中断服务程序)。简单地丢弃该条消息并向调用者返回错误信息。广播消息在此之前所有试图从队列中接收消息的任务此时都将获得相同的消息。该功能拷贝消息到各任务的消息缓冲中，并唤醒所有的等待任务。,3.3 接收消息,如果指定的消息队列中有消息，则将其中的第一条消息

36、拷贝到调用者的缓冲区，并从消息队列中删除它。如果此时消息队列中没有消息，则可能出现以下几种情况：永远等待消息的到达：等待消息的任务按FIFO或优先级高低顺序排列在等待队列中。等待消息且指定等待时限：等待消息的任务按FIFO或优先级高低顺序排列在等待队列中。不等待，强制立即返回。,限时等待可有效预防死锁。中断服务程序接收消息时必须选择不等待，因为中断服务程序是不能被阻塞的。如果消息队列被应用删除，则所有等待该消息队列的任务都被返回一个错误信息，并回复到就绪状态。,3.4 删除消息队列,从系统中删除指定的消息队列，释放消息队列控制块及消息队列缓冲区。任何知道此消息队列ID号的代码都可以删除它。消息

37、队列被删除后，所有等待从这个消息队列接收消息的任务都回到就绪态。,4 消息队列的其他典型使用,紧耦合的单向数据通信：发送任务发送消息后要求一个响应信号，表明接收任务已经成功接收到消息。,紧耦合的双向数据通信：如果数据需要在任务之间双向流动，则可以采用紧耦合的双向数据通信模式(也称为全双工通信)。,第四节事件,1 概述2 事件机制的主要数据结构3 典型的事件操作4 事件机制的典型应用,事件是指一种表明预先定义的系统事件已经发生的机制。用于任务与任务之间、任务与ISR之间的同步。主要的特点是可实现一对多的同步。一个事件就是一个标志，不具备其它信息。一个或多个事件构成一个事件集。事件集可以用一个指定

38、长度的变量(比如一个8bit,16bit或32bit的无符号整型变量，不同的操作系统其具体实现不一样)来表示，而每个事件由在事件集变量中的某一位来代表。,1 概述,事件及事件集有以下特点：事件间相互独立。事件仅用于同步，不提供数据传输功能。事件无队列多次发送同一事件，在未经过任何处理的情况下，其效果等同于只发送一次。事件机制的意义在于：当某任务要与多个任务或中断服务同步时，就需要使用事件机制。若任务需要与一组事件中的任意一个发生同步，可称为独立型同步(逻辑“或”关系)。任务也可以等待若干事件都发生时才同步，称为关联型同步(逻辑“与”关系)。,“或”同步和“与”同步,任务,任务,任务,任务,IS

39、R,ISR,OR,AND,“与”型同步,“或”型同步,事件集,事件集,POST,POST,PEND,PEND,用多个事件的组合发信号给多个任务,任务,任务,任务,ISR,OR,AND,事件集,事件集,事件集（8，16或32位）,POST,PEND,PEND,术语：发送事件集。指在一次发送过程中发往接收者(比如任务)的一个或多个事件的组合。待处理事件集。指已被发送到一个接收者，正在等待处理的所有事件的集合。事件条件“或”同步：待处理事件集只要包括等待的任一事件即可满足要求；“与”同步：待处理事件集必须包括等待的全部事件方可满足要求。,2 事件机制的主要数据结构,事件集控制块：管理所有创建的事件集

40、或者事件集附属于任务，不需创建，其相关参数成为任务控制块的一部分。,事件的内部实现机制实例说明C/OS-II,事件标志组数据结构typedef structINT8UOSFlagType;/指示本数据结构的类型void*OSFlagWaitList;/等待事件标志的任务链表OS_FLAGSOSFlagFlags;/各事件标志的当前状态OS_FLAG_GRP;事件标志节点数据结构typedef structvoid*OSFlagNodeNext;/后驱指针void*OSFlagNodePrev;/前驱指针void*OSFlagNodeTCB;/任务控制块指针void*OSFlagNodeFlag

41、Grp;/指回OS_FLAG_GRP结构OS_FLAGSOSFlagNodeFlags;/所等待的事件标志组合INT8UOSFlagNodeWaitType;/等待类型(与、或)OS_FLAG_NODE;,事件标志组、事件标志节点及任务控制块之间的关系,OS_FLAG_GRP,OS_FLAG_NODE,.OSTCBFlagNodeFlagGrp.OSFlagNodeFlags.OSFlagNodeWaitType.OSFlagNodeNext.OSFlagNodePrev.OSFlagNodeTCB,.OSFlagWaitList.OSFlagFlags.OSFlagType,AND or O

42、R,AND or OR,AND or OR,OS_EVENT_TYPE_FLAG,0,0,.OSTCBFlagNode,OS_TCB,3 典型的事件操作,创建事件集删除事件集发送事件(集)接收事件(集)获取有关事件集的各种信息,3.1 创建事件集,申请空闲事件集控制块，设置事件集属性，初始化控制块中的域，分配ID号。,创建一个事件标志组OSFlagCreate(),OS_FLAG_GRP*OSFlagCreate(OS_FLAGS flags,INT8U*err)OS_FLAG_GRP*pgrp;pgrp=OSFlagFreeList;/获取一个空闲事件标志组结构if(pgrp!=(OS_FL

43、AG_GRP*)0)/获取成功，初始化该结构中的域OSFlagFreeList=(OS_FLAG_GRP*)OSFlagFreeList-OSFlagWaitList;/调整空闲结构链头指针pgrp-OSFlagType=OS_EVENT_TYPE_FLAG;pgrp-OSFlagFlags=flags;/初始化当前各事件标志的状态pgrp-OSFlagWaitList=(void*)0;/尚无任务等待事件标志*err=OS_NO_ERR;else*err=OS_FLAG_GRP_DEPLETED;return(pgrp);,3.2 接收事件(集),在接收事件(集)时可以有如下选项,OS_FL

44、AGS OSFlagPend(OS_FLAG_GRP*pgrp,OS_FLAGS flags,INT8U wait_type,INT16U timeout,INT8U*err)OS_FLAG_NODE node;/OS_FLAG_NODE作为局部变量存在于调用该函数的任务堆栈中OS_FLAGS flags_cur;OS_FLAGS flags_rdy;switch(wait_type)case OS_FLAG_WAIT_SET_ALL:/任务以“与”方式等待事件标志flags_rdy=pgrp-OSFlagFlags,接收(等待)事件标志组的事件标志位OSFlagPend(),case OS_

45、FLAG_WAIT_SET_ANY:/任务以“或”方式等待事件标志 flags_rdy=pgrp-OSFlagFlags,OS_Sched();/当前任务被放到事件标志等待链后，内核实施任务调度if(OSTCBCur-OSTCBStat,OS_FLAG_GRP,OS_EVENT_TYPE_FLAG,AND or OR,AND or OR,0,0,OS_TCB,OS_TCB,OSTCBCur,OS_FLAG_NODE,0,添加一个任务到事件标志组等待任务链表中OS_FlagBlock(),OS_FLAGS OSFlagAccept(OS_FLAG_GRP*pgrp,OS_FLAGS flags,

46、INT8U wait_type,INT8U*err)OS_FLAGS flags_cur,flags_rdy;*err=OS_NO_ERR;switch(wait_type)/判断等待事件标志的方式 case OS_FLAG_WAIT_SET_ALL:/”与”方式等待 flags_rdy=pgrp-OSFlagFlags,接收(无等待地获取)事件标志OSFlagAccept(),case OS_FLAG_WAIT_SET_ANY:/”或”方式等待 flags_rdy=pgrp-OSFlagFlags,3.3 发送事件(集),调用者(任务或中断)构造一个事件(集)，将其发往接收者(比如目标任务)

47、。可能会出现以下几种情况之一：目标任务正在等待的事件条件得到满足，任务就绪；目标任务正在等待的事件条件没有得到满足，该事件(集)被按“或”操作，保存到目标任务的待处理事件集中，目标任务继续等待；目标任务未等待事件(集)，该事件(集)被按“或”操作，保存到目标任务的待处理事件集中。,OS_FLAGS OSFlagPost(OS_FLAG_GRP*pgrp,OS_FLAGS flags,INT8U*err)OS_FLAG_NODE*pnode;BOOLEAN sched=FALSE;/初始化调度标志OS_FLAGS flags_cur,flags_rdy;pgrp-OSFlagFlags|=fla

48、gs;/置位事件标志pnode=(OS_FLAG_NODE*)pgrp-OSFlagWaitList;/获取任务等待链头节点while(pnode!=(OS_FLAG_NODE*)0)/如果有任务等待，遍历等待链switch(pnode-OSFlagNodeWaitType)case OS_FLAG_WAIT_SET_ALL:/”与”方式等待 flags_rdy=pgrp-OSFlagFlags,发送(置位)事件标志组中的事件标志OSFlagPost(),case OS_FLAG_WAIT_SET_ANY:/”或”方式等待 flags_rdy=pgrp-OSFlagFlags,3.4 删除事件

49、集,回收事件集控制块到空闲链中，等待接收该事件集的任务被恢复就绪。,删除事件标志组OSFlagDel(),OS_FLAG_GRP*OSFlagDel(OS_FLAG_GRP*pgrp,INT8U opt,INT8U*err)BOOLEAN tasks_waiting;OS_FLAG_NODE*pnode;if(pgrp-OSFlagWaitList!=(void*)0)tasks_waiting=TRUE;/有任务等待 else tasks_waiting=FALSE;/无任务等待 switch(opt)case OS_DEL_NO_PEND:/在无任务等待时才删除事件标志组if(tasks_

50、waiting=FALSE)/无任务等待，释放控制块到空闲链中 pgrp-OSFlagType=OS_EVENT_TYPE_UNUSED;pgrp-OSFlagWaitList=(void*)OSFlagFreeList;OSFlagFreeList=pgrp;*err=OS_NO_ERR;return(OS_FLAG_GRP*)0);else/有任务等待，删除失败*err=OS_ERR_TASK_WAITING;return(pgrp);,case OS_DEL_ALWAYS:/无论是否有任务等待，都删除事件标志组 pnode=(OS_FLAG_NODE*)pgrp-OSFlagWaitLi