Код: int kernel_GetMessage( MSG * msg ) // msg е за резултатно съобщение за нас
{
task_id = OS_GET_CURRENT_TASK_ID(); // само за този таск
while( 1 )
{
OS_QUEUE_GET( task_id, &queue_task_record, WAIT_FOREVER ); // всеки таск си има негово си queue
// пример за това от FreeRTOS е: BaseType_t xQueueReceive( QueueHandle_t xQueue, void *pvBuffer, TickType_t xTicksToWait );
// xTicksToWait задава време за блокиравка на таска ... в нашия случай WAIT_FOREVER
switch( queue_task_record.message_id ) // обработка на истинските кернел съобщения
{
case MSG_UART_RX:
find: user_uart_callback()
execute: user_uart_callback( params )
break; // демек goto while(1) в началото
case MSG_TIMER:
find: user_timer_callback()
execute ...
и пак while()
case други системни съобщения:
и те така докато:
case MSG_USER:
копи данни от queue_task_record към msg за нас ... в случая msg->ID(съобщение), msg->param1, msg->param2 и msg->task_sourse_id (от къде идва съобщениетo)
и изход от тук с return 0
// след изхода следва да си обработим каквото е дошло за нас...
// например: SIM картата е готова или Модема е свързан към провайдера и други такива
// това тук разпределя и мулти-таск съобщения между наши таскове
}
}
} | 
