Поиск исключений в многопроцессорной обработке Python

У меня есть фрагмент кода на Python, который выглядит так:

procs = cpu_count()-1
if serial or procs == 1:
    results = map(do_experiment, experiments)
else:
    pool = Pool(processes=procs)     
    results = pool.map(do_experiment, experiments)

Он работает нормально, когда я устанавливаю флаг serial, но это дает следующую ошибку, когда используется пул . Когда я пытаюсь напечатать что-то из do_experiment, ничего не появляется, поэтому я не могу попробовать/поймать там и распечатать трассировку стека.

Exception in thread Thread-2:
Traceback (most recent call last):
  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/threading.py", line 530, in __bootstrap_inner
    self.run()
  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/threading.py", line 483, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/pool.py", line 285, in _handle_tasks
    put(task)
TypeError: 'NoneType' object is not callable

Как можно продолжить отладку?

5
задан noio 30 May 2012 в 15:29
поделиться