Система обмена сообщения между отдельными модулями программы Опции

[Слесарь]

Здравствуйте!
Программирую на С под 8-бит микроконтроллер. Для улучшения динамики работы ПО хочу сделать нечто подобное как сообщения Виндовс. Каждому отдельному модулю ПО выделяется процессорное время, только не квант времени как в Виндовс, а передается процессор на обработку всего что обрабатывает модуль, естественно, модуль должен как можно скорее вернуть процессор для работы следующих модулей. Должен проверить свои данные и сообщения, если новых данных/сообщений нет, вернуть процессор для работы других модулей ПО, следующий по порядку, по кругу.

Отдельные модули ПО могут добавлять сообщения в общий список, другие модули могут получать сообщения и обрабатывать.
Планирую сделать две функции доступные из всех модулей ПО SendMessage и GetMessage, в функции будет передаваться/приниматься хейдер сообщенияи данные. Функция SendMessage добавляет сообщение с указанием хейдера в динамичный список сообщений. Функция GetMessage извлекает сообщение с указанным хейдером или если сообщение отсутствует возвращает NO_MESSAGE.

Вопрос в следующем:
Допустим один модуль шлет сообщения, но еще не существует модуля который может эти сообщения обрабатывать, список сообщений будет расти. Какое должно быть время жизни сообщений, чтоб не забить всю память? Сообщение должно пройти через все модули ПО по кругу и должно уничтожится вернувшись в модуль отправитель?

Правильно ли я мыслю?

[zöner]

посмотрите в сторону Protothreads - там есть неблокирующее ожидание условий.
и главное - без привязки к какой-либо архитектуре, чистый С.
расход кода на задачу - мизерный.

[Слесарь]

посмотрите в сторону Protothreads - там есть неблокирующее ожидание условий.

Скорее всего у меня тож самое, только без макросов в которые завернут С код. Да и ссылками на функции я не оперирую, у меня просто бесконечный цикл, типо так:

Код

main()
{
    while(1)
    {
        MSC1205_Task();
        SIM900_Task();
        IR_Task();
        TimeTask();
        PRESS_Task();
    }

Еще я создаю централизованную систему обмена сообщениями между отдельными модулями, вот например:

Код

SIM900_Task()
{
char power;
char dtmfStD;
char dtmfCode;
MESSAGE message;
  
  // удаление ранее отправленных сообщений если таковые имелись
    DeleteMessage( MESSAGE_SIM900_DTMF );
    DeleteMessage( MESSAGE_SIM900_RING );
    
    // ....
    
    // Посылка новых сообщений если произошло событие
    if( power && dtmfStD )
    {
        SendMessage( MESSAGE_SIM900_DTMF, dtmfCode );
    }
    
    if( sim900_response_char == 0x32 ) // 2 -ring
    {
        sim900_response_char = 0x00;
        SendMessage( MESSAGE_SIM900_RING, 0 );
    }

// прием сообщений от других модулей

    message = GetMessage( MESSAGE_SIM900_DISCONNECT );
    if( message.message != MESSAGE_NO )
    {
        dtmfOn = 0;
    
        str32[0] = 0x00;
        strcatpgm2ram( str32, ( void *)"ATH" );
        SIM900_SendATComand( str32 );
    }