Я создал пул процессов Python с функцией multiproccessing.pool, любой из которых выполняет аналогичную работу. Это делается для того, чтобы больше работы выполнялось одновременно.
Я бы хотел, чтобы все задачи ожидали одного события/сигнала/semafore или другого объекта, задачи которого находятся в спящем режиме до тех пор, пока не будет получен сигнал. Они выполнят свою работу, а затем снова перейдут в спящий режим, ожидая повторного запуска этого события.
Другие задачи в программе вызовут событие, когда у них есть работа, которую необходимо выполнить.
Другие задачи в программе инициируют это событие, когда у них есть работа, которую необходимо выполнить.
Другие задачи в программе запускают это событие.
p>
Я не уверен, что я могу использовать для публикации событий другими задачами, когда они требуют выполнения работы. Я не уверен, как заставить эти задачи ждать этого сигнала.
При использовании Pool() задачи представляют собой разные процессы, но всем им необходимо пробуждаться от какого-то общего сигнала.
Подробнее здесь: https://stackoverflow.com/questions/790 ... e-up-event
