Форум сайта python.su
Добрый день. Подскажите, пожалуйста, кто знает, можно ли во время выполнения процессов 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
Отредактировано robisho (Дек. 22, 2022 04:04:58)
Офлайн
https://www.pythonguis.com/faq/pause-a-running-worker-thread/
Офлайн
Офлайн