python serial 多线程读写-CFANZ编程社区

Python Serial 多线程读写

简介

串口通信是一种常见的硬件通信方式，常用于与设备进行数据交换。在Python中，我们可以使用serial模块来实现串口通信功能。然而，当需要同时进行串口读写操作时，单线程的方式可能会导致读写阻塞。为了解决这个问题，我们可以利用多线程的特性，实现并行的串口读写。

本文将介绍如何使用Python的多线程功能来实现串口的并行读写操作。我们将使用serial模块来创建串口对象，并使用threading模块来实现多线程处理。

安装依赖

首先，我们需要安装serial模块和threading模块。可以使用以下命令来安装：

pip install pyserial

示例代码

下面是一个示例代码，演示了如何使用多线程读写串口数据。

import serial
import threading

# 创建串口对象
ser = serial.Serial('COM1', 9600)

# 创建读取线程
def read_thread():
    while True:
        try:
            if ser.in_waiting:
                data = ser.readline().decode().strip()
                print(f'Received: {data}')
        except serial.SerialException as e:
            print(f'Error reading from serial port: {e}')
            break

# 创建写入线程
def write_thread():
    while True:
        try:
            data = input('Enter data to send: ')
            ser.write(data.encode())
        except serial.SerialException as e:
            print(f'Error writing to serial port: {e}')
            break

# 启动线程
read_t = threading.Thread(target=read_thread)
write_t = threading.Thread(target=write_thread)
read_t.start()
write_t.start()

在上述代码中，我们首先创建了一个串口对象ser，通过指定串口号和波特率来进行初始化。然后，我们创建了两个线程read_thread和write_thread，分别用于读取和写入串口数据。

读取线程中，我们不断地检查串口的输入缓冲区是否有数据可读取，如果有，则读取数据并打印。写入线程中，我们通过input函数获取用户输入的数据，并将其写入到串口中。

最后，我们使用threading.Thread类创建了两个线程对象read_t和write_t，分别关联到read_thread和write_thread函数，并通过start方法启动线程。