Подсчет общего количества задач, выполненных в многопроцессорной обработке. Пул во время выполнения
Я хотел бы дать общее представление о текущем разговоре, что мы только. Я занимаюсь фермерством и хотел бы знать текущий прогресс. Так что если я отправил100
рабочие места для10
процессоры, как я могу показать текущее количество заданий, которые были возвращены. Я могу получить идентификаторы, но как подсчитать количество выполненных возвращенных заданий из функции карты.
Я вызываю свою функцию следующим образом:
op_list = pool.map(PPMDR_star, list(varg))
И в моей функции я могу напечатать текущее имя
current = multiprocessing.current_process()
print 'Running: ', current.name, current._identity