Мое понимание состоит в том, что, наконец, предложения должны всегда выполняться, если попытка была введена.
import random
from multiprocessing import Pool
from time import sleep
def Process(x):
try:
print x
sleep(random.random())
raise Exception('Exception: ' + x)
finally:
print 'Finally: ' + x
Pool(3).map(Process, ['1','2','3'])
Ожидаемый результат - это то, что для каждого из x, которое печатается самостоятельно по строке 8, должно быть возникновение "Наконец x".
Пример вывода:
$ python bug.py
1
2
3
Finally: 2
Traceback (most recent call last):
File "bug.py", line 14, in <module>
Pool(3).map(Process, ['1','2','3'])
File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/pool.py", line 225, in map
return self.map_async(func, iterable, chunksize).get()
File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/pool.py", line 522, in get
raise self._value
Exception: Exception: 2
Кажется, что исключение, завершающее один процесс, завершает родительский и родственный процессы, даже если в других процессах требуется дополнительная работа.
Почему я ошибаюсь? Почему это правильно? Если это правильно, как следует безопасно очищать ресурсы в многопроцессорном Python?