JavaScript で同時実行制御を実装する方法

const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
asyncPool(2, [1000, 5000, 3000, 2000], タイムアウトを待機します。)

関数 asyncPool(poolLimit, 配列, iteratorFn){ ... }

const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
asyncPool(2, [1000, 5000, 3000, 2000], タイムアウトを待機します。)
// イテレータを呼び出す (i = 1000)
// イテレータを呼び出す (i = 5000)
// プールの制限 2 に達しました。早い方の完了を待ちます...
// 1000 フィニッシュ
// イテレータを呼び出す (i = 3000)
// プールの制限 2 に達しました。早い方の完了を待ちます...
// 3000 フィニッシュ
// イテレータを呼び出す (i = 2000)
// 反復処理が完了しました。実行中の反復処理が完了するまで待機します...
// 5000 フィニッシュ
// 2000 終了
// 解決され、結果は指定された配列の順序 `[1000, 5000, 3000, 2000]` で渡されます。

非同期関数 asyncPool(poolLimit, 配列, iteratorFn) {
  const ret = []; // すべての非同期タスクを保存 const performing = []; // 実行中の非同期タスクを保存 for (const item of array) {
    // iteratorFn 関数を呼び出して非同期タスクを作成します const p = Promise.resolve().then(() => iteratorFn(item, array));
    ret.push(p); // 新しい非同期タスクを保存 // poolLimit 値がタスクの総数以下の場合は、同時実行制御を実行します if (poolLimit <= array.length) {
      // タスクが完了したら、実行中のタスクの配列から完了したタスクを削除します。const e = p.then(() => execute.splice(executing.indexOf(e), 1));
      実行中の非同期タスクを保存する if (executing.length >= poolLimit) {
        await Promise.race(executing); // より高速なタスクが完了するまで待機します }
    }
  }
  Promise.all(ret) を返します。
}

関数 asyncPool(poolLimit, 配列, iteratorFn) {
  i = 0 とします。
  const ret = []; // すべての非同期タスクを保存 const performing = []; // 実行中の非同期タスクを保存 const enqueue = function () {
    if (i === 配列の長さ) {
      Promise.resolve() を返します。
    }
    const item = array[i++]; // 新しいタスク項目を取得します。const p = Promise.resolve().then(() => iteratorFn(item, array));
    ret.push(p);

    r = Promise.resolve() とします。

    // poolLimit値がタスクの総数以下の場合、同時実行制御を実行します。if (poolLimit <= array.length) {
      // タスクが完了したら、実行中のタスクの配列から完了したタスクを削除します。const e = p.then(() => execute.splice(executing.indexOf(e), 1));
      実行中.push(e);
      実行中の長さ >= poolLimit の場合 {
        r = Promise.race(実行中);
       }
    }

     // 実行中のタスク リスト内のより高速なタスクが完了すると、配列から新しいタスクが取得されます。array return r.then(() => enqueue());
  };
  enqueue() を返します。その後 (() => Promise.all(ret));
}

Promise.all = 関数 (イテレータ) {
  新しい Promise を返します ((resolve, reject) => {
    if (!イテレータ || イテレータの長さ === 0) {
      解決する（[]）;
    } それ以外 {
      let count = 0; // すべてのタスクが完了したかどうかを判断するために使用されるカウンター let result = []; // 結果配列 for (let i = 0; i < iterators.length; i++) {
        // iterators[i] は通常のオブジェクトである可能性があることを考慮して、Promise オブジェクトとしてパッケージ化されます Promise.resolve(iterators[i]).then(
          (データ) => {
            result[i] = data; // 対応する結果を順番に保存します // すべてのタスクが完了したら、結果を均一に返します if (++count === iterators.length) {
              解決(結果);
            }
          },
          (エラー) => {
            reject(err); // いずれかの Promise オブジェクトの実行に失敗した場合は、reject() メソッドが呼び出されます。 return;
          }
        );
      }
    }
  });
};

Promise.race = 関数 (イテレータ) {
  新しい Promise を返します ((resolve, reject) => {
    for (イテレータの定数イテレータ) {
      Promise.resolve(イテレータ)
        .then((res) => {
          解決する(res);
        })
        .catch((e) => {
          拒否する
        });
    }
  });
};