[问答]

一个线程可以从两个不同消息队列读写数据吗

如下图所属结构，5个线程，用到了3个消息队列，2个信号量，可行吗？不行就得用全局变量来控制了。

消息类型定义

typedef struct

{

rt_uint8_t cmd;     //1 :DTU 2 :realtime 3 :other

rt_uint8_t addr;    //从机地址

rt_uint8_t index;   //读取的数据是第几条，实时数据是8，dtu数据是8

rt_uint8_t finish;  //是否接收完成 0 未完成 1完成

}message_t;

发送线程一个等待线程，一个接收线程

while(1)

// for(rt_uint8_t i=COMM_SN;i<24;i++)

// {

// if(SET_DAT.uc[COMM_SN]==1)break;

// else

// {

// COMM_SN++;

// if(COMM_SN>23)return;

// }

num = find_valid_machine(list, 24);

    rd_real_time(list[i]);

    msg_send.addr = list[i] + 1;

//这里是发送给接收线程，告诉接收线程按照什么方式解析数据，设备地址

    result = rt_mq_send(&mq, &msg_send, sizeof(msg_send));

    if (result != RT_EOK)

    {

        rt_kprintf("rt_mq_send ERR\n");

    }

//这是从接收线程读取队列，知道数据是否处理完成

result = rt_mq_recv(&mq, &msg_recv, sizeof(msg_recv),1000);

    if (result == RT_EOK)

    {

        //比较发送时的地址、指令、条目编号

        if (msg_recv.addr == msg_send.addr && msg_send.cmd == msg_recv.cmd && msg_send.index == msg_recv.index)

        {

            if (msg_recv.finish == 1)//判断接收完成

            {

                msg_send.cmd = 1;//发送读取dtu数据的指令

                msg_send.finish = 0;//发送未完成

                result = rt_mq_send(&mq, &msg_send, sizeof(msg_send));

                rd_dtu_data(list[i],1,1,0);//dtu数据

                if (result != RT_EOK)

                {

                    rt_kprintf("rt_mq_send ERR\n");

                }

            }

        }

    }

    rt_memset(&msg_recv, 0, sizeof(msg_recv));

    result = rt_mq_recv(&mq, &msg_recv, sizeof(msg_recv),1000);

    if (result == RT_EOK)

    {

        if (msg_recv.addr == msg_send.addr && msg_send.cmd == msg_recv.cmd && msg_send.index == msg_recv.index)

        {

            // if (msg_recv.finish == 1)

            // {

                i++;//不管是否有dtu数据，i都会自加，和下一个地址的机器通信

            // }

        }

    }

    rt_thread_delay(1000);    

}

这是接收线程

while(1)

{

    rt_uint16_t i,j,n = 0;    

    rt_uint8_t crc=0,addr;

    if (result == RT_ERROR)

    {

    }

//从发送线程接收消息队列，得到解析数据的方式。不知道为什么，接收之后，result是0xFFFFFFFE，问题就出在这里

    result = rt_mq_recv(&mq, &msg_recv, sizeof(msg_recv),1000);

    if (result == RT_EOK)

    {

        if(msg_recv.cmd == 2)//读取实时数据

        {

            rt_uint16_t len = 0;

            if(recv_ok == 1)

            {

                if (USART3_RX_BUF[0] == msg_recv.addr)

                {

                    // len = USART3_RX_BUF[2]<<8 + USART3_RX_BUF[3];

                    for(rt_uint16_t i=0;i<(USART3_RX_LEN+6-2);i++)

                    {

                        crc+=USART3_RX_BUF[i];

                    }

                    if ((crc ==USART3_RX_BUF[USART3_RX_LEN-1]) && (COMM_addr3==USART3_RX_BUF[0]))

                    {

                        if(USART3_RX_BUF[1]==0x10)//向环控器写入数据后，收到环控器返回数据

                        {

                            //printf("写入环控器后收到环控器返回的信息%d\n",USART3_RX_BUF[2]);

                            if((USART3_RX_BUF[2]>=1)&&(USART3_RX_BUF[2]<=7))

                            {

                                RS485_OK=USART3_RX_BUF[2];

                            }    

                            if((USART3_RX_BUF[2]>=9)&&(USART3_RX_BUF[2]<=11))

                            {

                                RS485_OK=USART3_RX_BUF[2]-1;

                            }    

                        }

                        else if (USART3_RX_BUF[1]==0x03)

                        {

                            addr=COMM_addr3-1;    

                            COMM_OK[addr]=1;//这里是控制实时数据页面显示绿色 红色 灰色

                            for(rt_uint8_t i=0;i<160;i++)

                            {

                                    SSSJ.uc[addr][i]=USART3_RX_BUF[4+i];

                            }

                            msg_send = msg_recv;

                            msg_send.finish = 1;

                            //发送队列，告诉发送线程指定的数据已经解析完成

                            rt_mq_send(&mq, &msg_send, sizeof(msg_send));

                        }

                    }

                }

            }

        }

        else if (msg_recv.cmd == 1)

        {

            //DTU模式，不用解析，直接发送

            rt_device_write(dev, 0, USART3_RX_BUF,USART3_RX_LEN);

            msg_send = msg_recv;

            msg_send.finish = 1;//finish不重要，0或者1，都需要和下一台机器通信了

            msg_send.cmd = 1;//说明是DTU通信

            rt_mq_send(&mq, &msg_send, sizeof(msg_send));

        }

    }

2022-8-2 10:11:50　　评论 淘帖0 邀请回答

您可以邀请以下用户，快速回答问题

ss
该类别下有 100 个回答。

邀请回答
chunhuahua
该类别下有 55 个回答。

邀请回答
而无返还
该类别下有 47 个回答。

邀请回答
最强海贼王
该类别下有 45 个回答。

邀请回答
王尚岱
该类别下有 45 个回答。

邀请回答
河神大人
该类别下有 43 个回答。

邀请回答
万航渡路
该类别下有 40 个回答。

邀请回答
nhcp
该类别下有 40 个回答。

邀请回答
wonick
该类别下有 39 个回答。

邀请回答
青sky
该类别下有 38 个回答。

邀请回答
mintsy
该类别下有 38 个回答。

邀请回答
熊本熊
该类别下有 37 个回答。

邀请回答
h1654155272.9717
该类别下有 36 个回答。

邀请回答
其实znvm
该类别下有 36 个回答。

邀请回答
zhongnian
该类别下有 36 个回答。

邀请回答
糖栗子
该类别下有 35 个回答。

邀请回答
小野七七
该类别下有 35 个回答。

邀请回答
juju宇哥
该类别下有 34 个回答。

邀请回答
星星公交站
该类别下有 33 个回答。

邀请回答
梅利号
该类别下有 33 个回答。

邀请回答

nhcp

撰写答案

你正在撰写答案

如果你是对答案或其他答案精选点评或询问，请使用“评论”功能。

声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表德赢Vwin官网网立场。文章及其配图仅供工程师学习之用，如有内容图片侵权或者其他问题，请联系本站作侵删。侵权投诉

我要提问

精选推荐

AI模型部署边缘设备的奇妙之旅：目标检测模型

590 浏览 0 评论
AI模型部署边缘设备的奇妙之旅：如何在边缘端部署OpenCV

2241 浏览 0 评论
tms320280021 adc采样波形，为什么adc采样频率上来波形就不好了？

1233 浏览 0 评论
基于米尔全志T527开发板的OpenCV进行手势识别方案

1788 浏览 0 评论
AI模型部署边缘设备的奇妙之旅：如何实现手写数字识别

1464 浏览 0 评论

答案对人有帮助，有参考价值 0 可以，别用 RT_WAITING_FOREVER，改成等待若干 ms 。然后判断返回值，如果是超时继续读下一个消息。如果不是超时进入消息处理。

2022-8-2 10:13:41 评论举报 zhongnian

答案对人有帮助，有参考价值 0 写了一下，接收消息队列的时候，返回值是没读到，为什么没有挂起呢，反而执行接收队列语句后面的语句

2022-8-2 10:13:50 评论举报 nhcp

答案对人有帮助，有参考价值 0 ？？？怎么会没有返回值。永久阻塞等待变成定时等待，当然会返回执行后面的语句，你看上面我说了两句话，你只看了一句吗？判断返回值，根据返回值是不是OK再处理“接收队列语句后面的语句”

2022-8-2 10:13:58 评论举报 zhongnian

答案对人有帮助，有参考价值 0 我的意思是返回值不是RTEOK，是0xFFFFFFFE，跟那些标志位都对不上。

2022-8-2 10:14:08 评论举报 nhcp

答案对人有帮助，有参考价值 0 0xFFFFFFFE 不就是超时？！！！判断非 OK 返回值要用它的负值！！！ if (ret == -RT_ETIMEOUT) { // timeout todo }

2022-8-2 10:14:17 评论举报 zhongnian

答案对人有帮助，有参考价值 0 就是-2，-RT_ETIMEOUT，异常的返回值都加了负号的

2022-8-2 10:14:23 评论举报 zhongnian

搜索历史

一个线程可以从两个不同消息队列读写数据吗

相关推荐

撰写答案

精选推荐

热门帖

站长推荐 /6