事件组

	事件组	同步点
创建	xEventGroupCalc = xEventGroupCreate();//1，创建事件组	xEventGroupSyc = xEventGroupCreate()
设置	xEventGroupSetBits(xEventGroupCalc,(1<<0));//设置事件组bit0 位	xEventGroupSync(xEventGroupSyc,BUSYING,ALL,portMAX_DELAY); //BUSYING = 1 << 0, //ALL = 1 << 0 | 1 << 1 | 1 << 2
等待	xEventGroupWaitBits(xEventGroupCalc,(1<<0)|(1<<1),pdTRUE,pdTRUE,portMAX_DELAY); //xclearonexit:退出是否清除。xwaitforallbits：是否等待所有的事件位有数据	/
总结	1，事件组解决多个生产者，都在产生数据时，各自往对应的bit位给状态通知。 2，消费者等待不同的bit未是否完成，可以是等待所有位也可以只等待其中一个完成。 3，事件组只能传递完成状态，而不能传递数据，传递数据还要通过队列方式	1，同步点，创建同事件组。 2，设置不同于事件组，要传递对应位以及所有需要同步的位的组合。 3，当所有任务都放入事件组，标志位都以完成，才能退出阻塞。

1，事件组由一组标志位组成，每一个标志位代表一个特定的时间。

任务可以等待某些标志位被置位或清除。

2，队列，信号量。都是只能共用标志位，无法多标志多个事件。

3，事件组包含，事件创建，生产者1，写bit0，生产者2，写bit1.

消费者等待bit0或bit1。也可以只等待其中一个bit0。

/*
任务1，sum++，sum 每加到1000次后，往队列存放数据，并且记录事件组bit0
任务2，dec--，dec 每减到1000次后，往队列存放数据，并且记录事件组bit1
任务3，等待事件组，bit0，bit1同时标志时，从队列中取出数据打印
*/
static int sum = 0;
static int dec = 0;
static QueueHandle_t qHandle_f1;
static QueueHandle_t qHandle_f2;
static EventGroupHandle_t xEventGroupCalc;void Task1function(void *param)
{int i;while(1){for(i=0;i<1000;i++){sum++;}xQueueSend(qHandle_f1, &sum, portMAX_DELAY);xEventGroupSetBits(xEventGroupCalc,(1<<0));//设置事件组bit0 位}
}
void Task2function(void *param)
{int i;while(1){for(i=0;i<1000;i++){dec--;}xQueueSend(qHandle_f2, &dec, portMAX_DELAY);xEventGroupSetBits(xEventGroupCalc,(1<<1));//设置事件组bit1 位}
}
void Task3function(void *param)
{int val_sum;int val_dec;while(1){xEventGroupWaitBits(xEventGroupCalc,(1<<0)|(1<<1),pdTRUE,pdTRUE,portMAX_DELAY);//xclearonexit:退出是否清除。xwaitforallbits：是否等待所有的事件位有数据xQueueReceive(qHandle_f1,&val_sum,portMAX_DELAY);xQueueReceive(qHandle_f2,&val_dec,portMAX_DELAY);printf("sum = %d,dec=%d\r\n",val_sum,val_dec);}
}
int main( void )
{prvSetupHardware();printf("Hello, world!\r\n");qHandle_f1 = xQueueCreate(10,sizeof(int));qHandle_f2 = xQueueCreate(10,sizeof(int));xEventGroupCalc = xEventGroupCreate();//1，创建事件组xTaskCreate(Task1function, "Task1", 100,NULL, 1, NULL);//xTaskCreate(Task2function, "Task2", 100,NULL, 1, NULL);//xTaskCreate(Task3function, "Task3", 100,NULL, 1, NULL);///* Start the scheduler. */vTaskStartScheduler();/* Will only get here if there was not enough heap space to create theidle task. */return 0;
}

同步点

当多个时间同时完成后，执行后面的操作。否则后面的操作处于阻塞状态。

/*
任务1，买菜    buying
任务2，炒菜    cooking
任务3，摆桌    tableing当3个任务都完成时，吃饭 eating
*/
typedef enum
{BUYING =  1 << 0,COOKING = 1 << 1,TABLEING = 1 << 2,ALL = 1 << 0 | 1 << 1 | 1 << 2  
}eWork_t;
static EventGroupHandle_t xEventGroupSyc;
static SemaphoreHandle_t xSemapMutex;void Task1function(void *param)
{while(1){xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task1 is buying\r\n");xSemaphoreGive(xSemapMutex);xEventGroupSync(xEventGroupSyc,BUYING,ALL,portMAX_DELAY);xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task1 is eating\r\n");xSemaphoreGive(xSemapMutex);vTaskDelay(2);}
}void Task2function(void *param)
{while(1){xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task2 is cooking\r\n");xSemaphoreGive(xSemapMutex);xEventGroupSync(xEventGroupSyc,COOKING,ALL,portMAX_DELAY);xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task2 is eating\r\n");xSemaphoreGive(xSemapMutex);vTaskDelay(2);}
}
void Task3function(void *param)
{while(1){    xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task3 is tableing\r\n");xSemaphoreGive(xSemapMutex);xEventGroupSync(xEventGroupSyc,TABLEING,ALL,portMAX_DELAY);xSemaphoreTake(xSemapMutex, portMAX_DELAY);printf("task3 is eating\r\n");xSemaphoreGive(xSemapMutex);vTaskDelay(2);}
}
int main( void )
{prvSetupHardware();printf("Hello, world!\r\n");xEventGroupSyc = xEventGroupCreate();//创建同步点xSemapMutex = xSemaphoreCreateMutex();//创建互斥锁xTaskCreate(Task1function, "Task1", 100,NULL, 3, NULL);//xTaskCreate(Task2function, "Task2", 100,NULL, 2, NULL);//xTaskCreate(Task3function, "Task3", 100,NULL, 1, NULL);///* Start the scheduler. */vTaskStartScheduler();/* Will only get here if there was not enough heap space to create theidle task. */return 0;
}