1

我正在尝试使用该pathos库来替换内置的多处理库,但是在 Windows 上使用管道或队列时遇到了困难。这是一个有代表性的例子:

from pathos.helpers import mp
#import multiprocessing as mp

def f(pipe, queue):
    if sys.gettrace():
        print 'Debug mode. About to crash'
    else:
        print 'Execute mode'
    pipe.send('pipe')
    queue.put('queue')


if __name__ == '__main__':
    mp.freeze_support()

    to_child, to_self = mp.Pipe()
    queue = mp.Queue()
    p = mp.Process(target=f, args=(to_child, queue))
    p.start()
    p.join()

pipe.send('pipe')提高IOError: (6, 'The handle is invalid')queue.put('queue')提高WindowsError: [Error 5] Access is denied。两者都可以使用 vanilla 多处理模块正常工作。

难道我做错了什么?

编辑:此崩溃仅在我尝试调试子进程时发生(我使用WingIDE)。sys.gettrace()如上所述,我可以通过检查来准确预测崩溃。

4

1 回答 1

0

事实证明,当Wing IDE 设置为调试子进程时,就会出现问题。据我了解,wing 通过在父进程和子进程之间插入自身来启用子进程调试(这意味着“子”进程现在实际上是父进程的孙子进程)。在 Windows 上,这可以通过猴子补丁使 Popen在调用句柄时multiprocessing设置“可继承”标志成为可能。Trueduplicate()

如果没有inheritable设置,孙子进程将无法访问句柄,因此会引发上述异常。

似乎可以将一个类似的猴子补丁应用到pathos'shelpers.mp模块以允许wing 调试子进程pathos

于 2015-11-19T18:19:37.023 回答