async/await と asyncio はどのように動作しますか？

Question

Accepted Answer

**asyncio** は `async`/`await` を使った **並行 I/O** のための Python のフレームワークです。イベントループを介して、多数の I/O 操作を**単一スレッド**上で協調的に実行します。スレッドのオーバーヘッドなしに、高い並行性を要する I/O バウンド処理（ネットワーク呼び出し、Web サーバー）に効率的です。

## コルーチンの定義と実行

```python
import asyncio

async def fetch_data(id):       # an async function = a coroutine
    print(f"start {id}")
    await asyncio.sleep(1)       # await a non-blocking I/O operation (yields control)
    print(f"done {id}")
    return id

asyncio.run(fetch_data(1))       # run a coroutine from sync code
```

`async def` 関数は**コルーチン**です。`await` は I/O の地点でコルーチンを中断し、その間イベントループが*他の*コルーチンを実行できるようにします。そして待機していた操作が完了すると再開します。

## 主な利点: 並行 I/O

```python
# ❌ sequential — total time ≈ 3 seconds
async def slow():
    await fetch_data(1)   # wait 1s
    await fetch_data(2)   # then wait 1s
    await fetch_data(3)   # then wait 1s

# ✅ concurrent — total time ≈ 1 second (all run together)
async def fast():
    await asyncio.gather(fetch_data(1), fetch_data(2), fetch_data(3))
```

`asyncio.gather` はコルーチンを**並行して**実行します。1 つが I/O を待機している間に、他のコルーチンが進行します。3 つの 1 秒待機が重なり合い、合計で約 1 秒になります。これが中核的な価値です。多数の I/O 待機を 1 つのスレッド上で重ね合わせるのです。

## スレッドとの違い

```text
Threading:  OS-managed, preemptive, real threads (GIL-limited for CPU)
asyncio:    single thread, COOPERATIVE — coroutines yield at `await` points
            → lighter weight (handle thousands of connections), no thread overhead,
              but one CPU-heavy coroutine blocks everything (no preemption)
```

## 鉄則: イベントループをブロックしない

```python
async def bad():
    time.sleep(5)              # ❌ BLOCKS the whole event loop (sync sleep)
    result = heavy_compute()    # ❌ CPU work freezes all coroutines

async def good():
    await asyncio.sleep(5)      # ✅ non-blocking
    # offload CPU work to a thread/process pool
    await loop.run_in_executor(None, heavy_compute)
```

協調的かつ単一スレッドであるため、ブロッキングや CPU 負荷の高い呼び出しは*すべての*コルーチンを凍結させます。`await` 可能な非同期 API を使い、ブロッキングや CPU 処理は executor にオフロードしましょう。

## asyncio が真価を発揮する場面

```text
✓ High-concurrency I/O: web servers (FastAPI), web scraping, many API/DB calls,
  websockets, real-time apps — thousands of concurrent connections efficiently
✗ CPU-bound work — use multiprocessing instead (asyncio doesn't help)
```

## なぜ重要なのか

asyncio は Python における**高並行 I/O** の現代的なアプローチであり、FastAPI のようなフレームワークを支え、単一スレッド上で数千の同時接続を効率的に処理できます。これはスレッド-per-接続方式よりもはるかに軽量です。

コルーチン、`await`、`gather` による並行実行、そして特に**鉄則**（イベントループを決してブロックせず、CPU/ブロッキング処理をオフロードする）を理解することは、高性能な非同期 Python を書くために不可欠です。

asyncio が適している場面（I/O バウンドの並行処理）と適していない場面（CPU バウンド → multiprocessing）を知ることが、効果的に使う鍵です。