异步从两个串行端口读取
异步从两个串行端口读取
提问于 2016-05-29 00:39:42
我想在Linux上的python中同时读取两个(或更多)串行端口(/dev/ttyUSB0等)。我想从每个端口读取完整的行(以有数据者为准)，并按收到的顺序处理结果(没有竞争条件)。作为一个简单的例子，可以将行写到一个合并的文件中。
我认为这种方法是基于pyserial的，但我不太清楚如何做到这一点。Pyserial使用异步和线程进行非阻塞读取.Asyncio被标记为实验性的。我假设如果在asyncio.Protocol.data_received()中完成处理，就不会有任何争用条件。在线程的情况下，处理可能必须由互斥保护。
也许这也可以用吡咯烷酮来完成。这两个串口可以作为文件打开，然后在数据可用时使用select()读取。
回答 3
Stack Overflow用户
回答已采纳
发布于 2016-07-30 09:14:03
正如@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也许可以更优雅地写这篇文章，但它很有效。
Stack Overflow用户
发布于 2018-09-24 22:33:20
考虑使用异种材料。
下面是一个例子：
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),
]))Stack Overflow用户
发布于 2016-05-29 05:34:18
您可以尝试按顺序取值，并在变量中记忆它：
a = data1.read ()
b = data2.read ()经过处理后，以便：
If len (a) != 0 or len (b ) != 0:
Process a
Process b如果其中一个或两个值都有数据，则使用此方法处理
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/37505062
复制相关文章
相似问题
腾讯云开发者
