0

我正在尝试子类wx.Process化，以便我有一个自定义的进程启动器，它使用从标准输出流收集的数据将事件触发回主线程。这是做事的好方法吗？

class BuildProcess(wx.Process):
    def __init__(self, cmd, notify=None):
       wx.Process.__init__(self, notify)
       print "Constructing a build process"
       self.Bind(wx.EVT_IDLE, self.on_idle)
       self.Redirect()
       self.cmd = cmd
       self.pid = None

   def start(self):
       print "Starting the process"
       self.pid = wx.Execute(self.cmd, wx.EXEC_ASYNC, self)
       print "Started."

   def on_idle(self, evt):
       print "doing the idle thing..."
       stream = self.GetInputStream()
       if stream.CanRead():
          text = stream.read()
          wx.PostEvent(self, BuildEvent(EVT_BUILD_UPDATE, self, data=text))
          print text

   def OnTerminate(self, *args, **kwargs):
       wx.Process.OnTerminate(self, *args, **kwargs)
       print "Terminating"

BuildEvent这是一个自定义子类wx.PyEvent。该进程正在正确启动、运行和终止，但我的on_idle函数从未执行，即使我确定我已将其绑定到空闲事件。

4

2 回答 2

1

目标不是调用另一个进程的方法，目标是通过进程执行时定期触发的“更新”事件将另一个进程的标准输出重定向回父进程。

一种解决方案是使用 wx.Timer 定期轮询进程的输出流，这样我们就不会依赖 EVT_IDLE 为我们完成工作（我无法让 EVT_IDLE 触发）

class BuildProcess(wx.Process):

    def __init__(self, cmd, notify=None):
        wx.Process.__init__(self, notify)
        self.Redirect()
        self.cmd = cmd
        self.pid = None
        self.timer = wx.Timer(self)
        self.Bind(wx.EVT_TIMER, self.on_timer)

    def start(self):
        wx.PostEvent(self, BuildEvent(EVT_BUILD_STARTED, self))
        self.pid = wx.Execute(self.cmd, wx.EXEC_ASYNC, self)
        self.timer.Start(100)

    def on_timer(self, evt):
        stream = self.GetInputStream()
        if stream.CanRead():
            text = stream.read()
            wx.PostEvent(self, BuildEvent(EVT_BUILD_UPDATE, self, data=text))


    def OnTerminate(self, *args, **kwargs):
        print "terminating..."
        stream = self.GetInputStream()
        if stream.CanRead():
            text = stream.read()
            wx.PostEvent(self, BuildEvent(EVT_BUILD_UPDATE, self, data=text))
        if self.timer:
            self.timer.Stop()
        wx.PostEvent(self, BuildEvent(EVT_BUILD_FINISHED, self))

通过这种方法，每 100 毫秒输出流被读取、打包并作为构建事件发送。

于 2009-04-07T12:32:47.283 回答
0

从查看 wxProcess 文档来看，我不认为它是这样工作的：wxProcess 将创建一个新的独立进程，作为当前进程的子进程运行。在这样的进程中，不可能运行连接到消息的方法。

也许您可以将空闲事件连接到主线程中的函数或方法。

或者，也许 wxThread 类是您真正想要使用的。

于 2009-04-07T07:28:52.040 回答