我目前使用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方法永远不会被调用.
基本上,我确信有一个简洁的方法让这个工作,我只是无法通过谷歌或反复试验找到它.任何人都可以向我建议我如何才能使这个工作？
提前感谢您提供的任何帮助,
西蒙
解决方法:
任何时候你想使用Twisted API但你的代码没有在与反应器相同的线程中运行,你可以使用reactor.callFromThread让反应器在你的线程中调用你的一些代码.所以,例如,你可以这样做：
def process_IN_CREATE(self, event):
reactor.callFromThread(
SerialPort, Handler(), "/dev/ttyACM1", reactor, baudrate='9600')
但是,您也不需要任何额外的线程来执行您所描述的操作.而不是使用pyinotify,使用twisted.internet.inotify：
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()
标签：python,serial-port,twisted 来源： https://codeday.me/bug/20190730/1578395.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。