У меня запущен параллельный процесс, но многопоточность занимает некоторое время (несколько се c) перед началом параллельного процесса.
Например:
results = Parallel(n_jobs=10, backend='threading', verbose=100)(delayed(test)(i) for i in range(0,300))
В приведенном выше примере тестовая функция вызывается за 300 итераций. результаты хороши, но требуется некоторое время для получения первых 10 результатов, а затем снова требуется несколько секунд, чтобы выдать следующие 10 результатов и т. д. ...
Есть ли решение для этого?
В идеале многопроцессорная / многопоточность должна использовать ядро / процессор непрерывно и не должна оставлять это бездействующим.
какое-либо решение для этого?