多线程下使用同一个串口发送数据导致数据混乱

紫气东升

使用GD32F405芯片，使用RTOS实时操作系统。最近调试机器时发现，当一个线程任务TASK1正通过UART0发送数据的时候，另一个线程任务TASK2也通过UART0发送数据。最终导致两个线程的数据混在一起了。
两个线程任务优先级一样。
比如说TASK1发送的数据是： ea 0b 01 73 cb 04 33 44 aa bb 0d

TASK2发送的数据是：ea 07 01 73 64 00 0d
最终通过串口助手看到的数据打印是：ea 0b 01 73 cb ea 07 01 04 33 73 64 00 0d 44 aa bb 0d，两组数据混在一起了，导致串口对方接收不到正确的数据。
哪位兄弟有什么好办法可以解决该问题？感谢！
void uart1_parse_task(void *parameter)
{
    while(1)
    {
        TransmitSocCommand(USART0, UART1_RS232_Buffer, UART1_RS232Cmd_Cnt);
        vTaskDelay(2);
    }
}


void uart2_parse_task(void *parameter)
{
    while(1)
    {
        TransmitSocCommand(USART0, UART2_RS232_Buffer, UART2_RS232Cmd_Cnt);
        vTaskDelay(2);
    }
}

void TransmitSocCommand(uint32_t usart_periph, uint8_t* data_buffer, uint16_t length)
{
    uint16_t n;

    for(n=0; n<length; n++)
    {
        usart_data_transmit(usart_periph, data_buffer[n]);
        while (RESET == usart_flag_get(usart_periph, USART_FLAG_TBE));
    }
}

八度空间

互斥信号量或者队列，做好标识

hehaiming

置标志位呗，然后另一个判读标志，这样就能错开两个发送的时机了。

xiaoxiaoren

用互斥信号量限制同时访问USART

a1281854907

自己重新定义一个线程安全的printf，其实也就是加锁，互斥锁，用完释放掉锁

紫气东升

参照网友的提议，使用消息队列方式处理多线程下同时使用一个串口发送数据。目前测试没出现数据混乱问题。***********************************
程序初始化：
#define QUEUE_RECEIVE_TASK_PRIO   (tskIDLE_PRIORITY + 6)
QueueHandle_t usart0_queue = NULL;

usart0_queue = xQueueCreate(50, 20);  //创建消息队列
xTaskCreate(queue_receive_task, "QUEUE_RECEIVE", configMINIMAL_STACK_SIZE/2, NULL, QUEUE_RECEIVE_TASK_PRIO, NULL);
*********************************
线程调用的发送数据函数：
/* 串口发送数据 */
void TransmitSocCommand(uint32_t usart_periph, uint8_t* data_buffer, uint16_t length)
{
    uint16_t n;
    BaseType_t xUsart0_Return = pdFALSE;

    switch(usart_periph)
    {
        case USART0:
            xUsart0_Return = xQueueSend(usart0_queue, data_buffer, 0);  //将要发送的数据放进消息队列中
            if(xUsart0_Return != pdPASS)
            {
                printf("send err\n");  //消息队列已满，放进数据失败
            }
            break;
        case USART1:
        case USART2:
            for(n=0; n<length; n++)
            {
                usart_data_transmit(usart_periph, data_buffer[n]);
                while (RESET == usart_flag_get(usart_periph, USART_FLAG_TBE));
            }
            break;
        default:
            break;
    }
}

*************************************
线程调用的接收数据函数：
uint8_t Queue_RecBuff[20] = {0};

void queue_receive_task(void *pvParameters)
{
    BaseType_t xRecResult = pdFALSE;
    uint16_t n;

    while(1)
    {
        xRecResult = xQueueReceive(usart0_queue, Queue_RecBuff, portMAX_DELAY);  //从消息队列中读取数据放到自己定义的Queue_RecBuff缓存中
        if(xRecResult == pdPASS)
        {
            for(n=0; n<Queue_RecBuff[1]; n++)
            {
                usart_data_transmit(USART0, Queue_RecBuff[n]);
                while (RESET == usart_flag_get(USART0, USART_FLAG_TBE));
            }
        }

        vTaskDelay(2);
    }
}