JavaScript/TypeScript で同時リクエスト制御を実装するためのサンプルコード

startTime を Date.now() とします。
const タイムアウト = (タイムアウト: 数値, ret: 数値) => {
 戻り値 (idx?: 任意) =>
 新しいPromise((resolve) => {
  タイムアウトを設定する(() => {
  const compare = Date.now() - startTime;
  console.log(`${Math.floor(compare / 100)}00 で return`, ret);
  解決(idx);
  }、 タイムアウト）;
 });
};

定数timeout1 = timeout(1000, 1);
定数timeout2 = timeout(300, 2);
定数timeout3 = タイムアウト(400, 3);
定数timeout4 = タイムアウト(500, 4);
定数timeout5 = タイムアウト(200, 5);

定数実行 = 非同期() => {
 開始時刻 = Date.now();
 Promise.all([ を待つ
 タイムアウト1()、
 タイムアウト2()、
 タイムアウト3()、
 タイムアウト4()、
 タイムアウト5()、
 ]);
};

走る（）;

200で5を返す
300で2を返す
400で3を返す
500で4を返す
1000で1を返す

クラスConcurrent {
 プライベートmaxConcurrent: 数値 = 2;

 コンストラクター(count: number = 2) {
 this.maxConcurrent = カウント;
 }
}

クラスConcurrent {
 プライベートmaxConcurrent: 数値 = 2;

 コンストラクタ(count: number = 2) {
 this.maxConcurrent = カウント;
 }
 パブリック非同期useRace(fns: Function[]) {
 const 実行中: any[] = [];
 // 同時実行数に応じて Promise を追加します // Promise はインデックスをコールバックするので、どの Promise が解決されたかを知ることができます (let i = 0; i < this.maxConcurrent; i++) {
  （fns.長さ）の場合{
  const fn = fns.shift()!;
  実行中.push(fn(i));
  }
 }
 定数ハンドル = 非同期() => {
  if (fns.length) {
  const idx = await Promise.race<number>(running);
  const nextFn = fns.shift()!;
  // 完了した Promise を削除し、新しいものを runing.splice(idx, 1, nextFn(idx)); に配置します。
  ハンドル（）;
  } それ以外 {
  // 配列がクリアされている場合は、実行される Promise がないことを意味します。これを Promise.all に変更できます。
  Promise.all(実行中) を待機します。
  }
 };
 ハンドル（）;
 }
}

定数実行 = 非同期() => {
 const コンカレント = 新しい Concurrent();
 開始時刻 = Date.now();
 同時実行のuseRace([タイムアウト1、タイムアウト2、タイムアウト3、タイムアウト4、タイムアウト5])を待機します。
};

300で2を返す
700で3を返す
1000で1を返す
1200に5を返す
1200に4に戻る

クラスConcurrent {
 プライベートmaxConcurrent: 数値 = 2;
 プライベートリスト: Function[] = [];
 プライベートcurrentCount: 数値 = 0;

 コンストラクタ(count: number = 2) {
 this.maxConcurrent = カウント;
 }
 パブリック非同期追加(fn:関数) {
 this.currentCount += 1;
 // 同時接続の最大数が最大値を超えた場合 if (this.currentCount > this.maxConcurrent) {
  // wait は Promise であり、resolve が呼び出される限り満たされます。const wait = new Promise((resolve) => {
  this.list.push(解決) を実行します。
  });
  //resolve が呼び出されない場合、ここで await wait がブロックされます。
 }
 //関数を実行する await fn();
 this.currentCount -= 1;
 if (this.list.length) {
  // 解決を取り出して呼び出すと、待機が完了し、以下を実行できるようになります。const resolveHandler = this.list.shift()!;
  ハンドラを解決します。
 }
 }
}

定数実行 = 非同期() => {
 const コンカレント = 新しい Concurrent();
 開始時刻 = Date.now();
 同時実行を追加します(タイムアウト1);
 同時実行を追加します(タイムアウト2)。
 同時実行を追加します(timeout3);
 同時実行を追加します(タイムアウト4)。
 同時実行を追加します(timeout5);
};

走る（）;

300で2を返す
700で3を返す
1000で1を返す
1200に5を返す
1200に4に戻る