對于一個數據采集線程，和一個數據接收線程而言。消息隊列相較于郵箱能夠傳輸不定長字節的數據。但是，對于數據采集線程，有時需要持續性采集多次的數據，每次都放進數組中，然后將他們一次性全部發送出去，這個時候就是需要注意
區分，我們到底是每次采完直接發送，，達到指定數據后才提醒接收線程接收。
還是將數據放在數組中，將數組一次性發出。
舉個簡單的例子，比如，線程1需要采集50個數據為1組發送給線程2
此時，線程1每接收一個發送一個，然后線程2統一接收。
#include <rtthread.h>
#define ARRAY_SIZE 50
static rt_mq_t mq;
static rt_sem_t sem;
static float data[ARRAY_SIZE];
static void producer_thread_entry(void *parameter)
{
float temp_data;
for (int i = 0; i < 50; i++)
{
// 采集數據
temp_data = ...; // 采集數據的邏輯
// 發送數據到消息隊列
rt_mq_send(mq, &temp_data, sizeof(float));
// 判斷是否采集了50次數據
if (i == 49)
{
// 發送信號量給消費者線程
rt_sem_release(sem);
}
rt_thread_mdelay(1000); // 延時 1 秒
}
}
static void consumer_thread_entry(void *parameter)
{
float received_data[ARRAY_SIZE];
while (1)
{
// 等待信號量
rt_sem_take(sem, RT_WAITING_FOREVER);
// 接收數據從消息隊列
for (int i = 0; i < ARRAY_SIZE; i++)
{
rt_mq_recv(mq, &received_data[ i], sizeof(float), RT_WAITING_FOREVER);
}
// 處理接收到的數據
for (int i = 0; i < ARRAY_SIZE; i++)
{
// 處理 received_data[ i]
}
}
}
int main(void)
{
mq = rt_mq_create("mq", sizeof(float), 50, RT_IPC_FLAG_FIFO);
if (mq == RT_NULL)
{
rt_kprintf("Failed to create message queue\n");
return -1;
}
sem = rt_sem_create("sem", 0, RT_IPC_FLAG_FIFO);
if (sem == RT_NULL)
{
rt_kprintf("Failed to create semaphore\n");
return -1;
}
rt_thread_t tid1 = rt_thread_create("producer", producer_thread_entry, RT_NULL, 1024, 10, 10);
if (tid1 != RT_NULL)
{
rt_thread_startup(tid1);
}
rt_thread_t tid2 = rt_thread_create("consumer", consumer_thread_entry, RT_NULL, 1024, 20, 10);
if (tid2 != RT_NULL)
{
rt_thread_startup(tid2);
}
while (1)
{
rt_thread_mdelay(1000);
}
}
[ i][ i]
這個時候，創建消息隊列的時候，就是
mq = rt_mq_create("mq", sizeof(float)，//每個消息的最大字節數
, 50 //消息隊列中最多有多少消息
,RT_IPC_FLAG_FIFO);
當我們將50個數據封裝程一個數組，然后將數組一次性通過消息隊列發送給線程2的時候
例如 定義數組 float value_data[50]; 存放數據
這個時候，創建的消息隊列應該是
mq = rt_mq_create("mq", sizeof(float)*50，//每個消息（這里的每個消息就是指的這個數組是一個消息）的最大字節數
, 3 //消息隊列中最多有多少消息，（隨便設定，實測，不易過大）
,RT_IPC_FLAG_FIFO);
這個特別注意，在創建消息隊列，傳輸數組的時候，數組作為消息發送的時候，單個消息的大小=sizeof(數組的存儲類型float)*數組深度
|
QQ好友和群
QQ空間
騰訊微博
騰訊朋友
收藏
淘帖
頂
踩
