使用pythontwisted框架连接多个串行套接字

Question

我目前使用twisted 连接到我拥有的串行设备，使用如下代码。

from twisted.internet import reactor
SerialPort(Handler(), "/dev/ttyACM1", reactor, baudrate='9600')
reactor.run()

但是，我知道需要扩展应用程序以监视添加（和删除）的新串行设备。我目前使用 pyinotify 来查找添加/删除的新设备，这似乎效果很好。

class EventHandler(pyinotify.ProcessEvent):
    def process_IN_CREATE(self, event):
        ... connect to serial device
        ...

目前我似乎有几个问题。我认为最大的问题是我对 Twisted 的了解还不够，不知道这样做的“正确”方法是什么。

目前，据我所知， pyinotify 事件处理程序在单独的线程中启动，这意味着反应器不在主线程中运行。这是一个问题吗？

连接第一个设备后，我很难添加第二个设备 - 尤其是在添加第二个设备时反应器已经在运行。即使我用

if not reactor.running: 

第二个连接来保护它，也不会正确添加到反应器中（至少connectionMade、dataReceived接收方法不会触发）。

如果我先启动反应器，然后让 pyinotify 事件尝试添加到正在运行的反应器，这似乎也不起作用 - 设备确实连接，但 dataReceived 方法永远不会被调用。

基本上，我确信有一个巧妙的方法可以让它发挥作用，但我只是无法通过谷歌或反复试验找到它。有人可以向我建议如何才能使其正常工作吗？

提前感谢您提供的任何帮助，

西蒙

Answer 1

每当您想要使用 Twisted API 但您的代码未在与反应器相同的线程中运行时，您都可以使用 reactor.callFromThread 让反应器在其线程中调用您的某些代码。因此，例如，您可以执行以下操作：

def process_IN_CREATE(self, event):
    reactor.callFromThread(
        SerialPort, Handler(), "/dev/ttyACM1", reactor, baudrate='9600')

但是，您也不需要任何额外的线程来执行您所描述的操作。使用 twisted.internet.inotify 代替 pyinotify：

from twisted.python.filepath import FilePath
from twisted.internet.inotify import IN_CREATE, INotify
from twisted.internet import reactor

def created(ignored, path, mask):
    SerialPort(
        Handler(),
        "/dev/ttyACM1", # Or... use `path` here?
        reactor, baudrate='9600')

notifier = INotify()
notifier.watch(FilePath("/some/directory"), IN_CREATE, callbacks=[created])
notifier.startReading()

reactor.run()