Я хочу иметь пул процессов, которые будут выполняться по одному и асинхронно с моей основной программой. При этом я хочу иметь возможность динамически добавлять новые процессы в этот пул, что-то вроде этого:
def async_slow_operation(arg):
pass
processes_pool = Pool()
for x in some_array:
res = do_some_slow_stuff(x)
processes_pool.add(async_slow_operation, res)
Таким образом, async_slow_operations будет выполняться во время do_some_slow_stuff, но не будет выполняться параллельно в пуле.
P.S. По сути, я хочу запустить нейронную сеть через пакетную загрузку изображений через bash, но не могу запустить несколько сетей одновременно.