Я использую asyncio для обработки сообщений в моем приложении. Он получает сообщение и определяет действия, которые будут выполняться в экземпляре ProcessPoolExecutor. С одной стороны, документация для concurrent.futures.ProcessPoolExecutor поддерживает идею разделения итераций для параллельного запуска их в разных рабочих процессах. С другой стороны, loop.run_in_executor передает аргументы как *args и ничего не упоминает об итеративной обработке.
Как передать итерируемое значение loop.run_in_executor для разбиения на блоки, как в базовом concurrent.futures.ProcessPoolExecutorиспользование