Карта пула Python висит, когда подпроцесс убит

Question

Я ударяю головой уже более дня, пытаясь понять, почему дети моей программы не могут вызвать какое-либо исключение и просто умереть, вместо того, чтобы зависеть целое Pool. Позвольте мне добавить, что я обыскал в Интернете часами, не нашел чего-то связанного.

Давайте рассмотрим в качестве примера:

#!/opt/perforce/bin/python/3.4.2/bin/python3 

import multiprocessing 
import sys 


def run(i): 
    print(i) 
    sys.exit(1) 

iteration = ['test1', 'test2', 'test3'] 

with multiprocessing.Pool(1) as pool: 
    pool.map(run, iteration) 
    print("reached here ?") 

с sys.exit(), печать никогда не достигается, pool.map вешает блоки по некоторым причинам. На моем подлинном скрипте добавлен sys.exit(), когда я поймаю какие-то ошибки. Я хотел бы умело убить рабочего (или просто пропустить итерацию, как перерыв). Я пробовал sys.exit(), exit() или даже os.kill(), но не повезло ...

Возможно ли это?

Answer 1

Я предлагаю, вы поднимаете Исключение и ловите его за пределами вызываемого. Пример:

import multiprocessing 
import sys 


def run(i): 
    print(i) 
    if i == 'test3': 
     raise Exception() 

iteration = ['test1', 'test2', 'test3'] 

with multiprocessing.Pool(1) as pool: 
    try: 
     result = pool.map(run, iteration) 
    except Exception: 
     sys.exit(1) 
    print("reached here ?")