多进程进程的输出的非阻塞重定向

Question

我昨天问了一个关于我用 Python 编写的程序的问题（ 传递 wxPython对象作为多处理器参数）。我通过对评估脚本的函数使用多进程进程来解决这个问题。但是，由于脚本是从不同的进程运行的，因此它们的输出没有正确重定向到我的 wxPython TextCtrl 窗口。因此，我正在寻找方法将子进程的输出持续重定向到我的主进程，以便可以将其写入我的文本窗口。

这是设置进程的函数：

def createprocess(test):
    q = Queue()
    q.put(test)
    p = Process(target=runtest, args=(q,))
    p.start()
    p.join()
    return q.get()

这​​是进程的目标函数：

def runtest(q):
    test = q.get()
    exec 'import ' + test
    func=test+'.'+test+'()'
    ret = eval(func)
    q.put(ret)

我找到了这个线程（ 如何将 python 多处理进程输出发送到 Tkinter gui ），它描述了如何重定向子进程的输出，但问题是输出是后收到评估已完成。

Answer 1

解决当前问题的方法是使用两个 Queue.Queue 而不是仅一个。我们将它们称为inqueue 和outqueue。然后

def runtest(inqueue,outqueue):
    test = inqueue.get()
    module=__import__(test)
    ret=getattr(module,test)()    
    outqueue.put(ret)

更大的问题涉及如何使用单独进程的输出来控制 GUI 元素（例如 TextCtrl）。答案是你不知道。相反，生成一个线程（如果您愿意，也可以生成其他进程），该线程可以从 outqueue 接收值，并（与单独的进程不同）更新 TextCtrl。
有关如何设置的示例，请参阅 LongRunningTasks wiki。