监听python中的线程事件



第一次SO用户,请原谅任何礼仪错误。我试图实现一个多线程程序在python和我有麻烦。毫无疑问,这是由于缺乏对线程是如何实现的理解,但希望你能帮我弄清楚。

我有一个基本的程序,不断地监听串行端口上的消息,然后可以打印/保存/处理等,这工作得很好。它看起来像这样:

import serial
def main():
    usb = serial.Serial('/dev/cu.usbserial-A603UBRB', 57600) #open serial w baud rate
    while True:
        line = usb.readline()
        print(line)

然而,我想做的是不断地监听串行端口上的消息,但不一定对它们做任何事情。这应该在后台运行,同时在前台,我希望有某种界面,用户可以命令程序读取/使用/保存这些数据一段时间,然后再次停止。

所以我创建了以下代码:
import time
import serial
import threading
# this runs in the background constantly, reading the serial bus input
class serial_listener(threading.Thread):
    def __init__(self, line, event):
        super(serial_listener, self).__init__()
        self.event = threading.Event()
        self.line = ''
        self.usb = serial.Serial('/dev/cu.usbserial-A603UBRB', 57600)
    def run(self):
        while True:
            self.line = self.usb.readline()
            self.event.set()
            self.event.clear()
            time.sleep(0.01)
# this lets the user command the software to record several values from serial
class record_data(threading.Thread):
    def __init__(self):
        super(record_data, self).__init__()
        self.line = ''
        self.event = threading.Event()
        self.ser = serial_listener(self.line,self.event)
        self.ser.start() #run thread
    def run(self):
        while(True):
            user_input = raw_input('Record data: ')
            if user_input == 'r':
                event_counter = 0
                while(event_counter < 16):
                    self.event.wait()
                    print(self.line)
                    event_counter += 1
# this is going to be the mother function
def main():
    dat = record_data()
    dat.start()
# this makes the code behave like C code.    
if __name__ == '__main__':
    main()    

它编译并运行,但是当我在CLI中输入r命令程序进行记录时,什么也没有发生。它似乎没有接收到任何事件。

有什么线索如何使它工作吗?解决方法也很好,唯一的问题是我不能不断打开和关闭串行接口,它必须一直保持打开状态,否则设备停止工作,直到运行/插电。

我建议使用多个进程而不是使用多个线程。在使用线程时,必须考虑全局解释器锁。所以你要么监听事件,要么在主线程中做一些事情。两者同时是行不通的。

当使用多个进程时,我会使用队列来转发您想要处理的看门狗事件。或者您可以编写自己的事件处理程序。这里可以找到一个多进程事件处理程序的示例

相关内容

  • 没有找到相关文章

最新更新