Task

asyncio.create_task 関数によるTaskの作成

>>> import asyncio
>>>
>>> async def func():
...     pass
...
>>> async def main():
...     task = asyncio.create_task(func())
...     print(type(task))
...
>>> asyncio.run(main())
<class '_asyncio.Task'>

Taskオブジェクトが生成される

単にコルーチンをawaitして実行

import asyncio
import time


async def main():
    await asyncio.sleep(2)
    await asyncio.sleep(5)


start = time.time()
asyncio.run(main())
print(f"time: {time.time() - start}")

実行結果: time: 7.0069193840026855

Taskを作成して実行

import asyncio
import time


async def main():
    task1 = asyncio.create_task(asyncio.sleep(2))
    task2 = asyncio.create_task(asyncio.sleep(5))
    await asyncio.gather(task1, task2)


start = time.time()
asyncio.run(main())
print(f"time: {time.time() - start}")

実行結果: time: 5.004063844680786

並行なTask実行

• awaitableオブジェクトを並行して実行

• asyncio.gather に渡されたシーケンスは並行実行される

asyncio.gatherにコルーチンを渡した例

import asyncio
import time


async def main():
    await asyncio.gather(asyncio.sleep(2), asyncio.sleep(5))


start = time.time()
asyncio.run(main())
print(f"time: {time.time() - start}")

実行結果: time: 5.007250785827637

練習問題

次のコードの get_status_code 関数を並行に実行する main 関数を作成してください

import asyncio
import time

import aiohttp


async def get_status_code(n):
    url = f"https://httpbin.org/delay/{n}"

    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:

            print("Status:", response.status)


start = time.time()
asyncio.run(get_status_code(3))
print(f"time: {time.time() - start}")