並行処理パターン

目次

• 概要
• 使用する場面
• クイックスタート
• リファレンスガイド
• ベストプラクティス

概要

適切な同期プリミティブとパターンを使用して、並列実行のための安全な並行コードを実装します。

使用する場面

• マルチスレッドアプリケーション
• 並列データ処理
• 競合状態の防止
• リソースプーリング
• タスク調整
• 高性能システム
• 非同期操作
• ワーカープール

クイックスタート

最小限の動作例:

class PromisePool {
  private queue: Array<() => Promise<any>> = [];
  private active = 0;

  constructor(private concurrency: number) {}

  async add<T>(fn: () => Promise<T>): Promise<T> {
    while (this.active >= this.concurrency) {
      await this.waitForSlot();
    }

    this.active++;

    try {
      return await fn();
    } finally {
      this.active--;
    }
  }

  private async waitForSlot(): Promise<void> {
    return new Promise((resolve) => {
      const checkSlot = () => {
        if (this.active < this.concurrency) {
          resolve();
// ... (詳細な実装はリファレンスガイドを参照)

リファレンスガイド

references/ ディレクトリの詳細な実装:

ベストプラクティス

✅ すべきこと

• 適切な同期プリミティブを使用する
• リソース枯渇を避けるために並行性を制限する
• 並行操作のエラーを処理する
• 可能な限り不変データを使用する
• 並行コードを十分にテストする
• 並行処理のパフォーマンスをプロファイリングする
• スレッドセーフの保証を文書化する

❌ してはいけないこと

• 同期なしで可変状態を共有する
• 調整に sleep/polling を使用する
• 無制限のスレッド/ワーカーを作成する
• 競合状態を無視する
• 非同期コードでイベントループをブロックする
• リソースのクリーンアップを忘れる