python coroutines

[yeomko22]

Reference

• https://docs.python.org/3/library/asyncio-task.html#coroutine

coroutine 개념

• 서브 루틴의 더 일반화 된 개념이다.
• 원래는 메인 루틴에서 함수를 호출하면 서브 루틴으로 진입하고, 함수가 종료되면 서브 루틴은 종료가 된다.
• 코루틴은 이 개념을 확장해서 함수 호출 시 진입하고, 빠져나갔다가 재진입 할 수 있다.
• 이를 이용해서 async / await가 구현된다.

coroutine을 만드는 방법

async def read_data(db):
    pass

@types.coroutine
def process_data(db):
    data = yield from read_data(db)
    ...

[yeomko22]

def asyncio

async def main():
    print('hello')
    await asyncio.sleep(1)
    print('world')

asyncio.run(main())

import asyncio
import time

async def say_after(delay, what):
    await asyncio.sleep(delay)
    print(what)

async def main():
    print(f"started at {time.strftime('%X')}")

    await say_after(1, 'hello')
    await say_after(2, 'world')

    print(f"finished at {time.strftime('%X')}")

asyncio.run(main())

• asyncio.run 함수로 실행시켜주어야 한다.
• await를 걸어주어야 한다.

async def main():
    task1 = asyncio.create_task(
        say_after(1, 'hello'))

    task2 = asyncio.create_task(
        say_after(2, 'world'))

    print(f"started at {time.strftime('%X')}")

    # Wait until both tasks are completed (should take
    # around 2 seconds.)
    await task1
    await task2

    print(f"finished at {time.strftime('%X')}")

• asyncio.create_task 함수를 이용해서 asyncio의 Task를 만들어준다.
• 이를 이용하면 concurrent하게 작업을 수행할 수 있다.

[yeomko22]

Awaitable

• await 구문을 사용할 수 있는 객체를 awaitable 하다고 부른다.
• 대표적인 예시로 coroutines, Tasks, Futures가 있다.
• 먼저 async def로 정의한 코루틴 자체는 awaitable하다. 다른 코루틴 내에서 await를 붙여서 호출 가능하다.

  
  import asyncio

async def nested(): return 42

async def main():

Nothing happens if we just call "nested()".

# A coroutine object is created but not awaited,
# so it *won't run at all*.
nested()

# Let's do it differently now and await it:
print(await nested())  # will print "42".

asyncio.run(main())

- generator based coroutine은 현재 deprecated 되었으며 3.10 버전에서부터는 삭제될 예정
- Task는 코루틴 스케쥴링을 concurrently하게 수행하고 싶을 때 사용한다.
~~~python
import asyncio

async def nested():
    return 42

async def main():
    # Schedule nested() to run soon concurrently
    # with "main()".
    task = asyncio.create_task(nested())

    # "task" can now be used to cancel "nested()", or
    # can simply be awaited to wait until it is complete:
    await task

asyncio.run(main())

• Future는 특별한 low level awaitable 객체이다. 이는 비동기 작업의 최종 결과물을 의미한다.
• 일반 애플리케이션 레벨에서는 건드릴 일이 없다.