ワーカープロセスの例外

Question

私はPythonでマルチプロセッシングをしています。あなたが「2」に印刷された数字を見ることができる場合

def a(num): 
    if(num == 2): 
     raise Exception("num can't be 2") 
    print(num) 


    p = Pool() 
    p.map(a, [2, 1, 3, 4, 5, 6, 7, 100, 100000000000000, 234, 234, 5634, 0000]) 

出力

3 
4 
5 
7 
6 
100 
100000000000000 
234 
234 
5634 
0 
multiprocessing.pool.RemoteTraceback: 
""" 
Traceback (most recent call last): 
    File "/usr/lib/python3.5/multiprocessing/pool.py", line 119, in worker 
    result = (True, func(*args, **kwds)) 
    File "/usr/lib/python3.5/multiprocessing/pool.py", line 44, in mapstar 
    return list(map(*args)) 
    File "<stdin>", line 3, in a 
Exception: Error, num can't be 2 
""" 

The above exception was the direct cause of the following exception: 

Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
    File "/usr/lib/python3.5/multiprocessing/pool.py", line 260, in map 
    return self._map_async(func, iterable, mapstar, chunksize).get() 
    File "/usr/lib/python3.5/multiprocessing/pool.py", line 608, in get 
    raise self._value 
Exception: Error, num can't be 2 

：私は、労働者がその例外を発生させる場合、私は、次のコードを書いたhappendsかを判断しようとしていますそこにはありませんが、なぜナンバー1もそこにいませんか？

注：私はデフォルトではUbuntuの

Answer 1

でPython 3.5.2を使用しています、プールはコアのあなたの数に等しい労働者の数を作成します。それらのワーカープロセスの1つが死ぬと、そのワーカープロセスに割り当てられた作業は元に戻すことができます。また、決してフラッシュされないバッファに出力を残すこともあります。 .MAP（）の結果は、一対一の入力を有することになっているからである。

.MAP（）のパターンは、労働者に例外を処理し、いくつかの適切なエラー値を返すことです

from multiprocessing import Pool 

def a(num): 
    try: 
     if(num == 2): 
      raise Exception("num can't be 2") 
     print(num, flush=True) 
     return num 
    except Exception as e: 
     print('failed', flush=True) 
     return e 

p = Pool() 
n=100 
results = p.map(a, range(n)) 

print("missing numbers: ", tuple(i for i in range(n) if i not in results)) 

ここにはhow exceptions propagate in multiprocessing.map workersについての詳しい情報がある別の質問があります。