事件组
| 事件组 | 同步点 | |
| 创建 | 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;
}
)
