from concurrent.futures import ProcessPoolExecutor
executor = ProcessPoolExecutor(max_workers=90)
def worker(p):
#много кода
dataset = [................................................] #большой список
for data in dataset:
future = executor.submit(worker, data)
Как в таком коде узнать какие задачи в произвольный момент времени выполняются, а какие в очереди?
Если это невозможно для ProcessPoolExecutor , если какой-то вариант многопроцессности, с которым это возможно и который также поддерживает ограничение количества процессов?