я пытаюсь правильно понять и реализовать два одновременно работающих Task объекты с использованием Python 3 относительно новые asyncio модуль.

в двух словах, asyncio, кажется, предназначен для обработки асинхронных процессов и параллельных Task исполнение в течение цикла обработки событий. Это способствует использованию await (применяется в асинхронных функциях) в качестве обратного вызова-бесплатный способ ждать и использовать результат, не блокируя цикл событий. (Фьючерс и обратные вызовы по-прежнему являются жизнеспособной альтернативой.)

он также обеспечивает asyncio.Task() класс, специализированный подкласс Future предназначена для упаковки сопрограммы. Предпочтительно вызывается с помощью asyncio.ensure_future() метод. Предполагаемое использование задач asyncio заключается в том, чтобы позволить независимо выполняемым задачам выполняться "одновременно" с другими задачами в том же цикле событий. Я так понимаю, что Tasks подключены к циклу событий, который затем автоматически продолжает управлять сопрограммой между await заявления.

мне нравится идея быть в состоянии использовать параллельные задачи без необходимости использовать Executor классы, но я не нашел много разработки по реализации.

вот как я сейчас это делаю:

import asyncio

print('running async test')

async def say_boo():
    i = 0
    while True:
        await asyncio.sleep(0)
        print('...boo {0}'.format(i))
        i += 1

async def say_baa():
    i = 0
    while True:
        await asyncio.sleep(0)
        print('...baa {0}'.format(i))
        i += 1

# wrap in Task object
# -> automatically attaches to event loop and executes
boo = asyncio.ensure_future(say_boo())
baa = asyncio.ensure_future(say_baa())

loop = asyncio.get_event_loop()
loop.run_forever()

в случае попытки одновременно запустить две задачи цикла, я заметил, что если задача не имеет внутреннего await выражение, оно застрянет в while петля, эффективно блокируя другие задачи от запуска (очень похоже на обычный while петли). Однако, как только задачи должны (а) ждать, они, кажется, работают одновременно без проблем.

таким образом,await операторы, кажется, обеспечивают цикл событий с опорой для переключения между задачами, давая эффект параллелизма.

пример вывода с внутренними await:

running async test
...boo 0
...baa 0
...boo 1
...baa 1
...boo 2
...baa 2

пример вывода без внутренние await:

...boo 0
...boo 1
...boo 2
...boo 3
...boo 4

вопросы

проходит ли эта реализация для "правильного" примера параллельных задач цикла в asyncio?

правильно ли, что это работает только для A Task чтобы обеспечить точку блокировки (await выражение) для того, чтобы цикл событий жонглировать несколькими задачами?