python - 属性错误 : '_MainProcess' object has no attribute '_exiting'

Question

我有一个

AttributeError: '_MainProcess' object has no attribute '_exiting'

来自 Python 应用程序。不幸的是，这段代码必须运行 Python 2.5，因此 processing 模块现在被称为 multiprocessing。我所做的是创建一个带有 Queue 的 Process 并从主进程put 一个项目到队列中。查看 processing.queue 代码，我可以看到馈线线程已启动。此馈线线程随后将检查 currentProcess()._exiting，但 currentProcess() 评估为 _MainProcess，它不具有上述属性在 processing.process 模块中看到。如何解决这个问题？它是 processing 中的错误吗？如果是，我可以使用 currentProcess()._exiting = False 简单地对其进行 monkeypatch 吗？

最小的例子:

#!/usr/bin/python

import processing
import processing.queue

class Worker(processing.Process):
    def __init__(self):
        processing.Process.__init__(self)
        self.queue = processing.queue.Queue()

    def run(self):
        element = self.queue.get()
        print element

if __name__ == '__main__':
    w = Worker()
    w.start()
    # To trigger the problem, any non-pickleable object is to be passed here.
    w.queue.put(lambda x: 1)
    w.join()

Answer 1

我不确定您为什么要在这种情况下对函数进行 pickle，如果您真的想这样做，请查看以下答案:Is there an easy way to pickle a python function (or otherwise serialize its code)?

否则，这适用于 python 2.6(我知道您正在寻找 2.5，但我没有 2.5)。我已将您的 lambda 函数替换为常规函数并将其提供给处理构造函数:

from multiprocessing import Process, Queue

def simple():
    return 1

class Worker(Process):
    def __init__(self, args):
        Process.__init__(self, args=args)
        self.queue = Queue()

    def run(self):
        element = self.queue.get()
        print element

if __name__ == '__main__':
    w = Worker(args=[simple])
    w.start()
    w.join()