Concurrency and Async

🚨 鉄則

競合状態を常に意識。シンプルに保つ。

並列実行

// ✅ 独立タスクは並列
const [users, products] = await Promise.all([
  fetchUsers(),
  fetchProducts()
]);

// ❌ 不要な順次実行
const users = await fetchUsers();
const products = await fetchProducts();

⚠️ 競合状態

// ❌ 競合あり(読み取り→待機→書き込み)
let count = 0;
async function increment() {
  const c = count;
  await delay(100);
  count = c + 1;  // 🚫 古い値ベース
}

// ✅ アトミック操作
await redis.incr('counter');

並列数制限

import pLimit from 'p-limit';
const limit = pLimit(5);  // ⚠️ 同時5つまで

await Promise.all(urls.map(url => limit(() => fetch(url))));

キャンセル

const controller = new AbortController();
setTimeout(() => controller.abort(), 5000);

await fetch(url, { signal: controller.signal });

🚫 デッドロック回避

// 順序付きロック(IDでソート)
const [first, second] = a.id < b.id ? [a, b] : [b, a];
await first.lock();
await second.lock();