Pythonのawaitによる非同期処理の制御と使い方をわかりやすく解説

# awaitの基本的な使い方
import asyncio

async def example():
    print("処理開始")
    await asyncio.sleep(2)  # 2秒待機
    print("処理再開")

asyncio.run(example())

# async関数をawaitで実行
import asyncio

async def task1():
    print("タスク1開始")
    await asyncio.sleep(3)
    print("タスク1完了")

async def task2():
    print("タスク2開始")
    await asyncio.sleep(2)
    print("タスク2完了")

async def main():
    await task1()  # task1が終わるまで待つ
    await task2()  # task2が終わるまで待つ

asyncio.run(main())

# 複数のタスクを並行実行
import asyncio

async def task(name, seconds):
    print(f"{name} 開始")
    await asyncio.sleep(seconds)
    print(f"{name} 完了")

async def main():
    await asyncio.gather(task("タスク1", 3), task("タスク2", 2))

asyncio.run(main())

# 非同期で複数のWebページを取得
import asyncio
import aiohttp  # 非同期HTTPリクエスト用ライブラリ

async def fetch(url):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            return await response.text()

async def main():
    urls = ["https://example.com", "https://example.org"]
    tasks = [fetch(url) for url in urls]
    results = await asyncio.gather(*tasks)
    for result in results:
        print(result[:100])  # 最初の100文字を表示

asyncio.run(main())