Я пытаюсь использовать ThreadPoolExecutor в Python, используя пакет резервного копирования Futures. Однако проблема в том, что все потоки выполняются одновременно, поэтому фактического объединения в пул не происходит. Точнее, я получаю 10 потоков этой функции вместо 5, а затем остальных. Я использую следующий код. Вы нашли что-то не так или это просто перенесенная реализация?
Спасибо!
with ThreadPoolExecutor(max_workers=5) as executor:
futures = [executor.submit(f, X, y) for t in range(10)]
for future in as_completed(futures):
self.trees.append(future.result())
Подробнее здесь: https://stackoverflow.com/questions/223 ... of-threads