小编sad*_*asd的帖子

Python 多处理挂起

下面是一分钟。可重现的代码:

import multiprocessing

class E(Exception):
    def __init__(self, a1, a2):
        Exception.__init__(self, '{}{}'.format(a1, a2))

def f(_):
    raise E(1, 2)

multiprocessing.Pool(1).map(f, (1,))
Run Code Online (Sandbox Code Playgroud)

这给出了以下错误:

Exception in thread Thread-5:
Traceback (most recent call last):
  File "/usr/lib/python3.7/threading.py", line 917, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 865, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/lib/python3.7/multiprocessing/pool.py", line 496, in _handle_results
    task = get()
  File "/usr/lib/python3.7/multiprocessing/contrnection.py", line 251, in recv
    return _ForkingPickler.loads(buf.getbuffer())
TypeError: __init__() missing 1 required positional argument: 'a2'
Run Code Online (Sandbox Code Playgroud)

有任何解决这个问题的方法吗?这里提到了类似的问题:https ://bugs.python.org/issue39751

python multiprocessing

5
推荐指数
1
解决办法
1174
查看次数

标签 统计

multiprocessing ×1

python ×1