具有修饰功能的多处理池使我“对象没有属性”

问题描述 投票:1回答:1

下面是可复制的代码:

from multiprocessing import Pool

def method_exception_catcher(method):

    def method_exception_caught(*args, **kwargs):

        try:
            return method(*args, **kwargs)

        except Exception as e:
            raise type(e)(str(e) + ' from [{}] method'.format(method.__name__)) 

    return method_exception_caught

class MyClass():

    @method_exception_catcher
    def do_something(self, elem):
        return 1/0

    @method_exception_catcher
    def parallel_do_something(self):

        with contextlib.closing(Pool(processes=1)) as p:

            procs = [p.apply_async(self.do_something, args=(3, )) for k in range(1)]
            results = [proc.get() for proc in procs]
            p.close()
            p.join()

        return results

MyClass().parallel_do_something()

该代码给我“ AttributeError:'MyClass'对象没有属性'method_exception_caught'”错误。

如何解决并成功将其除以0错误?谢谢!!

更新:

这里是完整的错误输出:

Process ForkPoolWorker-4:
Traceback (most recent call last):
  File "/usr/lib64/python3.6/multiprocessing/process.py", line 258, in _bootstrap
    self.run()
  File "/usr/lib64/python3.6/multiprocessing/process.py", line 93, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/lib64/python3.6/multiprocessing/pool.py", line 108, in worker
    task = get()
  File "/usr/lib64/python3.6/multiprocessing/queues.py", line 337, in get
    return _ForkingPickler.loads(res)
AttributeError: 'MyClass' object has no attribute 'method_exception_caught'

下面是可复制的代码:从多处理导入池中def method_exception_catcher(method):def method_exception_caught(* args,** kwargs):try:return method(* args,...

python python-multiprocessing
1个回答
0
投票

选择一个函数只是写下它的(模块和)名称

© www.soinside.com 2019 - 2024. All rights reserved.