1

Есть функция, определенная как async:

async def doStuff()

Необходимо таких функций вызвать много и параллельно. Пробую так:

with futures.ProcessPoolExecutor as pool:
        running = [await pool.submit(doStuff,arg1),await pool.submit(doStuff,arg2)]
        while running:
            done,running = futures.wait(running,timeout=30,return_when=ALL_COMPLETED)
            for future in done:
                session = future.result()
                print(session)

Однако, получаю ошибку

with futures.ProcessPoolExecutor as pool:
AttributeError: __enter__

Нельзя использовать async-функции в экзекьюторе?

1 ответ 1

0

Во-первых

with futures.ProcessPoolExecutor() as pool:

Во-вторых, сопрограмму надо запускать в цикле событий

async def do_async_stuff():
    ...

def do_stuff():
    asyncio.run(do_async_stuff())

Пример не самый удачный, только для демонстрации принципа.

В-третьих, зачем вам вообще ProcessPoolExecutor? Почему не просто

args = [arg1, arg2]
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait([doStuff(arg) for arg in args]))
2
  • Как тогда в этом случае получить результаты от выполнения doStuff()? Они мне нужны потом для выполнения другой операции. Я В случае двух аргументов мне надо дождаться получения обоих результатов, но когда экземпляров будет > 2, надо дождаться хотя бы два, а затем "подключать" каждый последующий.
    – Sergei
    22 дек 2018 в 17:40
  • Использовать gather вместо wait. 22 дек 2018 в 18:06

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.