关于消息队列、时间的接收响应冲突问题

发布于 2022-05-23 12:16:57 浏览：1016 订阅该版

```c
/***************************************************
****系统数据处理线程
*/
static	void	dataproc_thread_entry(void* parameter)
{
	uint8_t i;
	uint8_t Sys_Mode = 0;	
	rt_uint32_t recved;
	rt_err_t	wret;
	while(1)
	{
		//等待AD转换完成事件通知，超时时间1S
		wret = rt_event_recv(get_addata_event,AD_DATA_EVENT,RT_EVENT_FLAG_AND|RT_EVENT_FLAG_CLEAR,1000,&recved);
		if(wret == RT_EOK)												//-------AD转换完成事件正确接收
		{
			dataproc_tick++;
			
			//翻转AD转换指示灯
			if((dataproc_tick % 100) == 0)
			{
				DEV_LED_TOGGLE(AD_LED);
			}
		}
		else if(wret == (-RT_ETIMEOUT))					//-------等待AD转换完成事件超时
		{
			PRINT_ERR("Dataproc Timeout - recved:  %d \r\n",recved);
		}
		else																		//-------AD转换完成事件接收错误 
		{
			PRINT_ERR("Dataproc ThreadERR - sta: %d  recved:  %d \r\n",(uint8_t)wret,recved);;
		}
	}
}

/***************************************************
****系统数据通信线程
*/
static	void	datacomm_thread_entry(void* parameter)
{
	uint8_t i;
	rt_err_t	qret;	
	rt_uint32_t recved;	
	rt_uint8_t	mqdata_buff[256];																										//接收缓存区，比预定义的消息大小大一些
	while(1)
	{
//		qret = rt_mq_recv(data_comm_mq,mqdata_buff,sizeof(mqdata_buff),1);					//2秒超时等待，消息队列
		qret = rt_event_recv(test_event,AD_DATA_EVENT,RT_EVENT_FLAG_AND|RT_EVENT_FLAG_CLEAR,2000,&recved);
		if(qret == RT_EOK)													//接收到消息
		{
			//PRINT_RUN("接收到消息:%s",mqdata_buff);
		}
		else if(qret == (-RT_ETIMEOUT))							//接收超时
		{
//			PRINT_RUN("接收队列超时，发送实时数据！\r\n");
//			RealtimeData_Pack(&SysSTA_Data,&SysReal_Data,mqdata_buff);
//			Data_Uart_SendBuff(mqdata_buff,(mqdata_buff[3]<<8)|mqdata_buff[4]);
		}
		else																				//接收错误
		{
			PRINT_ERR("MQ队列接收错误: 0x%2x \r\n",(uint8_t)qret);
		}	
			
	}
}
```
初次使用RT_thread。。版本是nano最新版本，dataproc_thread_entry任务优先级是1，datacomm_thread_entry任务优先级是3.
现象是，假如datacomm_thread_entry任务不接收任何事件通知或者消息队列，直接延迟100ms，dataproc_thread_entry任务可以每秒响应10000次AD转换完成的任务通知。
但是datacomm_thread_entry中接收任务通知或者消息队列时，dataproc_thread_entry就会受到极大的影响。不知是何原因。。

2 个回答

xiaosela 2022-05-23

这家伙很懒，什么也没写！

lchnu 2022-05-23

Witness, Understand, Skill

xiaosela 2022-05-23

这家伙很懒，什么也没写！

请登录后再发布评论，点击登录

追加回复

出出啊 2022-05-23

恃人不如自恃，人之为己者不如己之自为也

xiaosela 2022-05-23

这家伙很懒，什么也没写！

//通信数据消息队列
```c
rt_mq_t	data_comm_mq	= RT_NULL;
//消息队列预分配的内存池。200*20
rt_uint8_t	mq_pool[4000];		
//消息队列中单条消息的最大值
#define	COMM_MQ_SIZE			200		
		
		rt_mq_init(data_comm_mq,"Comm_mq",mq_pool,COMM_MQ_SIZE,sizeof(mq_pool),RT_IPC_FLAG_FIFO);			//静态模式创建消息队列

rt_uint8_t	mqdata_buff[256];																										//接收缓存区，比预定义的消息大小大一些
qret = rt_mq_recv(data_comm_mq,mqdata_buff,sizeof(mqdata_buff),2000);					//2秒超时等待，消息队列
```
这是我定义的消息队列，我现在根本就不给它发任何消息，就是要它超时。。不过它会影响高优先级任务的 事件响应。
如果我在datacomm_thread_entry任务中等待消息队列，dataproc_thread_entry响应次数就变成下面这样了。
```
dataproc_tick:40(高优先级任务响应次数) 10042（中断发送任务通知次数）
[ERR] >> Dataproc Timeout - recved:  1 
dataproc_tick:1 10050
[RUN] >> 接收队列超时，发送实时数据！
dataproc_tick:40 10041
[ERR] >> Dataproc Timeout - recved:  1 
dataproc_tick:1 10051
[RUN] >> 接收队列超时，发送实时数据！
dataproc_tick:40 10042
[ERR] >> Dataproc Timeout - recved:  1 
dataproc_tick:1 10051
```

```c
static	void	datacomm_thread_entry(void* parameter)
{
	uint8_t i;
	rt_err_t	qret;	
	rt_uint32_t recved;	
	rt_uint8_t	mqdata_buff[256];																										//接收缓存区，比预定义的消息大小大一些
	while(1)
	{
//		qret = rt_mq_recv(data_comm_mq,mqdata_buff,sizeof(mqdata_buff),2000);					//2秒超时等待，消息队列
//		if(qret == RT_EOK)													//接收到消息
//		{
//			PRINT_RUN("接收到消息:%s",mqdata_buff);
//		}
//		else if(qret == (-RT_ETIMEOUT))							//接收超时
//		{
//			PRINT_RUN("接收队列超时，发送实时数据！\r\n");
//			RealtimeData_Pack(&SysSTA_Data,&SysReal_Data,mqdata_buff);
//			Data_Uart_SendBuff(mqdata_buff,(mqdata_buff[3]<<8)|mqdata_buff[4]);
//		}
//		else																				//接收错误
//		{
//			PRINT_ERR("MQ队列接收错误: 0x%2x \r\n",(uint8_t)qret);
//		}

rt_thread_mdelay(100);		
	}
}
```
屏蔽掉就是下面这样
```
dataproc_tick:10045 10045
dataproc_tick:10045 10045
dataproc_tick:10045 10045
dataproc_tick:10045 10045
dataproc_tick:10045 10045
dataproc_tick:10044 10044
dataproc_tick:10045 10045
```
不知道是哪里配置的有问题还是用法有问题