c - 具有多种消息类型的嵌入式 RTOS 生产者和消费者

标签 c multithreading embedded freertos rtos

<分区>

许多 RTOS 消息传递示例显示生产者生成像 int32 这样简单的东西,而消费者读取它。这很简单,因为您始终知道队列(或其他消息传递缓冲区)的类型和大小。

考虑从 GPS 读取数据的 RTOS 线程的情况。 GPS 可能有多种类型的消息。您无法保证消息何时到达、消息的顺序或消息的大小。每条消息都有很多字段,每条消息都可以表示为一个结构。

这个 GPS 处理生产者 RTOS 线程最好解析输入的数据流,然后将数据传递出去,以便消费者线程可以轻松读取 GPS 数据。

假设使用 FreeRTOS 或 CMSIS RTOS。如何最好地建立这种安排?将使用哪些原语?从根本上讲,我正在寻找一种干净的方法,将几种不同类型的不同大小的结构从生产者线程中传递出来,并在消费者中读取它们。

最佳答案

您可能会考虑使用指向消息的指针队列,而不是消息队列本身。这样,无论消息如何,队列中的每个项目都是固定大小(指针的大小)。

该技术确实需要谨慎的资源管理,以确保消息在接收方完成处理之前不会被修改、删除或重复使用。您需要一个分配-入队-出队-释放机制。

例如,给定:

enum eMessageType
{ AType, 
  BType
};

struct GenericMessage
{
    eMessageType type;
    char payload[0] ; // Note GCC zero-length array extension
};

struct A { struct GenericMessage, 
           uint32_t foo;
         };

struct B { struct GenericMessage,
           uint8_t bar;
         };

然后发件人可能有类似(伪代码)的东西:

 struct A* messageA = allocateMessageA( AType, 0x12345678 ) ;     
 struct B* messageB = allocateMessageB{ BType, 0x12 } ;

 sendGeneric( genericQ, messageA ) ;     
 sendGeneric( genericQ, messageB ) ;

和接收者:

 struct GenericMessage* message_ptr = receiveGeneric( genericQ ) ;
 switch( message_ptr->type )
 {
    case AType:
    {
        struct A* = (struct A*)message_ptr ;
        uint32_t payload = message_ptr->payload ;
        ...
        deallocateMessageA( message_ptr ) ;
    }
    break;

    case BType:
    {
        struct B* = (struct B*)message_ptr ;
        uint8_t payload = message_ptr->payload ;
        ...
        deallocateMessageB( message_ptr ) ;
    }
}  

我还没有定义分配/释放函数的细节。一种简单的方法是使用固定 block 内存池。如果您的 RTOS 不提供这些,一个简单的实现是在池中放置指向消息的指针队列,每个消息类型一个队列/池。要进行分配,您只需通过从队列中取出一条消息来从相关消息池中获取一个指针,然后通过将指针返回到队列中来解除分配。

请注意,某些 RTOS 允许直接发送可变长度的消息 - 例如,在 embOS 中,您可以为队列分配一个内存池,并在发送时指定长度,而不是在创建队列时指定长度。然而,接收方必须能够接收到尽可能多的消息。

关于c - 具有多种消息类型的嵌入式 RTOS 生产者和消费者,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51481194/

相关文章:

c - 在c中访问 union 成员

c - IAR Embedded Workbench - 设置变量的字节序

java - 处理文件下载等线程任务中的错误

ios - 如何在通过线程执行工作负载时为微调器设置动画

multithreading - 如何更好地解释 “deadlock”?

强制转换为 union 字段会产生转换警告

c - 静态变量未初始化为零

c - 错误 : More than one instance of overloaded function "sqrt" matches the argument list. 那是什么?

c - 找出数字 5 在 0 - 4322 内出现了多少次

c++ - ffmpeg命令行的c/c++程序