У меня есть алгоритм с компонентом итерации iteration(). Для поддержки нескольких процессоров я звоню pool.map(iteration, ...). Я хотел бы добавить шаг в моем алгоритме во время вызова iteration(), при котором ядро ожидает, пока все ядра не достигнут этой точки, и затем наилучшее решение распределяется между ядрами. В идеале у меня была бы просто другая функция share, которую я называю pool.map(share, ...), но этот пост подразумевает, что это не осуществимая техника.
Мой вопрос двоякий. Как я могу заставить все ядра останавливаться и ждать в течение вызова pool.map и как я могу применить функцию ко всем ядрам в вызове pool.map?