Добрый день. Подскажите, пожалуйста, кто знает, можно ли во время выполнения процессов multiprocessing.ThreadPool заблокировать всё для выполнения одной функции? Т.е. процессы работают, а как приходит время - запускается функция, скажем, проверки используемого в pool списка, и все процессы ждут, когда эта функция завершиться, чтобы подхватить измененный список и продолжить многопроцессорное выполнение основной функции?
from multiprocessing.pool import ThreadPool
with ThreadPool(num) as pool:
result = pool.imap_unordered(
run_smtp_send,
mail_list
)
for th in result:
pass