从两个串行端口异步读取

Question

我想在Linux上的python中同时读取两个（或更多）串行端口（/dev/ttyUSB0等）。 我想从每个端口（以有数据为准）读取完整的行，并按收到的顺序处理结果（无竞争条件）。 作为一个简单的示例，可以将行写入单个合并文件。

我认为执行此操作的方法基于 pyserial，但我无法完全弄清楚如何做到这一点。 Pyserial 具有使用 asyncio 和使用线程的非阻塞读取。 Asyncio 被标记为实验性。 我认为如果处理是在asyncio.Protocol.data_received()中完成的，则不会有任何竞争条件。 对于线程，处理可能必须由互斥锁保护。

也许这也可以在pyserial中完成。 两个串行端口可以作为文件打开，然后在数据可用时使用 select() 读取。

Answer 1

考虑使用 aioserial。

下面是一个示例：

import asyncio
import concurrent.futures
import queue
import aioserial

async def readline_and_put_to_queue(
        aioserial_instance: aioserial.AioSerial,
        q: queue.Queue):
    while True:
        q.put(await aioserial_instance.readline_async())

async def process_queue(q: queue.Queue):
    with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
        while True:
            line: bytes = await asyncio.get_running_loop().run_in_executor(
                    executor, q.get)
            print(line.decode(errors='ignore'), end='', flush=True)
            q.task_done()

q: queue.Queue = queue.Queue()
aioserial_ttyUSB0: aioserial.AioSerial = 
        aioserial.AioSerial(port='/dev/ttyUSB0')
aioserial_ttyUSB1: aioserial.AioSerial = 
        aioserial.AioSerial(port='/dev/ttyUSB1', baudrate=115200)
asyncio.run(asyncio.wait([
    readline_and_put_to_queue(aioserial_ttyUSB0, q),
    readline_and_put_to_queue(aioserial_ttyUSB1, q),
    process_queue(q),
]))

Answer 2

正如@AlexHall在评论中建议的那样，这里有一个解决方案，它为每个串行端口和一个队列使用一个线程来同步访问：

import serial
import Queue
import threading
queue = Queue.Queue(1000)
def serial_read(s):
    while True:
        line = s.readline()
        queue.put(line)
serial0 = serial.Serial('/dev/ttyUSB0')
serial1 = serial.Serial('/dev/ttyUSB1')
thread1 = threading.Thread(target=serial_read, args=(serial0,),).start()
thread2 = threading.Thread(target=serial_read, args=(serial1,),).start()
while True:
    line = queue.get(True, 1)
    print line

也许可以写得更优雅，但它有效。

Answer 3

您可以尝试按顺序获取值并将其存储在变量中：

a = data1.read ()
b = data2.read ()

按顺序处理后：

If len (a) != 0 or len (b ) != 0:
             Process a
             Process b

如果一个或两个值都有数据，请使用此方法进行处理