Python: как использовать async / await без asyncio? [Дубликат]

Корутинги должны иметь возможность

1. запускать
2. регулировать выход для вызывающего абонента (необязательно производить некоторые промежуточные результаты)
3. иметь возможность получить некоторую информацию от вызывающего абонента и резюме

Итак, вот небольшая демонстрация асинхронных функций (ака родных сопрограмм), которые делают это без использования asyncio или любых других модулей / фреймворков, которые обеспечивают цикл событий. Требуется хотя бы python 3.5. См. Комментарии внутри кода.

#!/usr/bin/env python

import types

# two simple async functions
async def outer_af(x):
    print("- start outer_af({})".format(x))
    val = await inner_af(x)  # Normal way to call native coroutine.
                             # Without `await` keyword it wouldn't
                             # actually start
    print("- inner_af result: {}".format(val))
    return "outer_af_result"


async def inner_af(x):
    print("-- start inner_af({})".format(x))
    val = await receiver()  # 'await' can be used not only with native
                            # coroutines, but also with `generator-based`
                            # coroutines!
    print("-- received val {}".format(val))
    return "inner_af_result"


# To yiled execution control to caller it's necessary to use
# 'generator-based' coroutine: the one created with types.coroutine
# decorator
@types.coroutine
def receiver():
    print("--- start receiver")
    # suspend execution / yield control / communicate with caller
    r = yield "value request"
    print("--- receiver received {}".format(r))
    return r

def main():
    # We want to call 'outer_af' async function (aka native coroutine)
    # 'await' keyword can't be used here!
    # It can only be used inside another async function.
    print("*** test started")
    c = outer_af(42)  # just prepare coroutine object. It's not running yet.
    print("*** c is {}".format(c))

    # To start coroutine execution call 'send' method.
    w = c.send(None)  # The first call must have argument None

    # Execution of coroutine is now suspended. Execution point is on
    # the 'yield' statement inside the 'receiver' coroutine.
    # It is waiting for another 'send' method to continue.
    # The yielded value can give us a hint about what exectly coroutine
    # expects to receive from us.
    print("*** w = {}".format(w))

    # After next 'send' the coroutines execution would finish.
    # Even though the native coroutine object is not iterable it will
    # throw StopIteration exception on exit!
    try:
        w = c.send(25)
        # w here would not get any value. This is unreachable.
    except StopIteration as e:
        print("*** outer_af finished. It returned: {}".format(e.value))


if __name__ == '__main__':
    main()

Вывод выглядит так:

*** test started
*** c is <coroutine object outer_af at 0x7f4879188620>
- start outer_af(42)
-- start inner_af(42)
--- start receiver
*** w = value request
--- receiver received 25
-- received val 25
- inner_af result: inner_af_result
*** outer_af finished. It returned: outer_af_result

Дополнительный комментарий. Похоже, что невозможно получить контроль изнутри собственной сопрограммы. yield не разрешено внутри функций async! Поэтому необходимо import types и использовать декоратор coroutine. Это черная магия! Честно говоря, я не понимаю, почему yield запрещен, поэтому требуется сборка сопрограмм на основе родных и генераторов.

Нет, это невозможно. Вам нужен цикл событий. Посмотрите, что произойдет, если вы просто назовете foo():

>>> f = foo()
>>> print(f)
<coroutine object foo at 0x7f6e13edac50>

Итак, вы получаете объект coroutine, ничего не запускается прямо сейчас! Только передавая его в цикл событий, он выполняется. Вы можете использовать asyncio или другой цикл событий, например Curio .

Pouton coroutines являются синтаксическим сахаром для генераторов, с некоторыми дополнительными ограничениями в их поведении (так что их назначение явно отличается и не смешивается). Вы не можете сделать:

next(foo())
TypeError: 'coroutine' object is not an iterator

, потому что он отключен явно. Однако вы можете сделать:

foo().send(None)
Hello
Hello
Hello
...

, что эквивалентно next() для генератора.