久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

標(biāo)題: RT_thread系統(tǒng)下通過(guò)消息隊(duì)列傳輸數(shù)組實(shí)現(xiàn)線(xiàn)程間通信 [打印本頁(yè)]

作者: liguanghui 時(shí)間: 2023-12-26 23:42
標(biāo)題: RT_thread系統(tǒng)下通過(guò)消息隊(duì)列傳輸數(shù)組實(shí)現(xiàn)線(xiàn)程間通信
對(duì)于一個(gè)數(shù)據(jù)采集線(xiàn)程，和一個(gè)數(shù)據(jù)接收線(xiàn)程而言。消息隊(duì)列相較于郵箱能夠傳輸不定長(zhǎng)字節(jié)的數(shù)據(jù)。但是，對(duì)于數(shù)據(jù)采集線(xiàn)程，有時(shí)需要持續(xù)性采集多次的數(shù)據(jù)，每次都放進(jìn)數(shù)組中，然后將他們一次性全部發(fā)送出去，這個(gè)時(shí)候就是需要注意
區(qū)分，我們到底是每次采完直接發(fā)送，，達(dá)到指定數(shù)據(jù)后才提醒接收線(xiàn)程接收。
還是將數(shù)據(jù)放在數(shù)組中，將數(shù)組一次性發(fā)出。
舉個(gè)簡(jiǎn)單的例子，比如，線(xiàn)程1需要采集50個(gè)數(shù)據(jù)為1組發(fā)送給線(xiàn)程2
此時(shí)，線(xiàn)程1每接收一個(gè)發(fā)送一個(gè)，然后線(xiàn)程2統(tǒng)一接收。
#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++)
{
      // 采集數(shù)據(jù)
      temp_data = ...;  // 采集數(shù)據(jù)的邏輯
      // 發(fā)送數(shù)據(jù)到消息隊(duì)列
      rt_mq_send(mq, &temp_data, sizeof(float));
      // 判斷是否采集了50次數(shù)據(jù)
      if (i == 49)
      {
         // 發(fā)送信號(hào)量給消費(fèi)者線(xiàn)程
         rt_sem_release(sem);
      }
      rt_thread_mdelay(1000);  // 延時(shí) 1 秒
}
}
static void consumer_thread_entry(void *parameter)
{
float received_data[ARRAY_SIZE];
while (1)
{
      // 等待信號(hào)量
      rt_sem_take(sem, RT_WAITING_FOREVER);
      // 接收數(shù)據(jù)從消息隊(duì)列
      for (int i = 0; i < ARRAY_SIZE; i++)
      {
         rt_mq_recv(mq, &received_data[ i], sizeof(float), RT_WAITING_FOREVER);
      }
      // 處理接收到的數(shù)據(jù)
      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]
這個(gè)時(shí)候，創(chuàng)建消息隊(duì)列的時(shí)候，就是
mq = rt_mq_create("mq", sizeof(float)，//每個(gè)消息的最大字節(jié)數(shù)
                                 , 50             //消息隊(duì)列中最多有多少消息
                                 ,RT_IPC_FLAG_FIFO);

當(dāng)我們將50個(gè)數(shù)據(jù)封裝程一個(gè)數(shù)組，然后將數(shù)組一次性通過(guò)消息隊(duì)列發(fā)送給線(xiàn)程2的時(shí)候
例如定義數(shù)組 float value_data[50]; 存放數(shù)據(jù)
這個(gè)時(shí)候，創(chuàng)建的消息隊(duì)列應(yīng)該是
mq = rt_mq_create("mq", sizeof(float)*50，//每個(gè)消息（這里的每個(gè)消息就是指的這個(gè)數(shù)組是一個(gè)消息）的最大字節(jié)數(shù)
                                 , 3             //消息隊(duì)列中最多有多少消息，（隨便設(shè)定，實(shí)測(cè)，不易過(guò)大）
                                 ,RT_IPC_FLAG_FIFO);

這個(gè)特別注意，在創(chuàng)建消息隊(duì)列，傳輸數(shù)組的時(shí)候，數(shù)組作為消息發(fā)送的時(shí)候，單個(gè)消息的大小=sizeof(數(shù)組的存儲(chǔ)類(lèi)型float)*數(shù)組深度

歡迎光臨 (http://m.zg4o1577.cn/bbs/)