JavaScript におけるシリアル操作と並列操作

var アイテム = [ 1, 2, 3, 4, 5, 6 ];
var 結果 = [];

関数 async(arg, コールバック) {
  console.log('パラメータは ' + arg +' です。1 秒後に結果を返します');
  setTimeout(function() { callback(arg * 2); }, 1000);
}

関数final(値) {
  console.log('完了しました: ', 値);
}

関数シリーズ(アイテム) {
  if(アイテム) {
    非同期(項目、関数(結果) {
      結果をプッシュします。
      return series(items.shift()); // すべてのデータを再帰的に実行します });
  } それ以外 {
    final(results[results.length - 1]) を返します。
  }
}

シリーズ(items.shift());

var アイテム = [ 1, 2, 3, 4, 5, 6 ];
var 結果 = [];

関数 async(arg, コールバック) {
  console.log('パラメータは ' + arg +' です。1 秒後に結果を返します');
  setTimeout(function() { callback(arg * 2); }, 1000);
}

関数final(値) {
  console.log('完了しました: ', 値);
}

items.forEach(function(item){// ループ完了 async(item, function(result){
    結果をプッシュします。
    if(results.length === items.length){// 完了した関数の数が実行される関数の数と等しいかどうかを判断します final(results[results.length - 1]);
    }
  })
});

var アイテム = [ 1, 2, 3, 4, 5, 6 ];
var 結果 = [];
var 実行中 = 0;
var 制限 = 2;

関数 async(arg, コールバック) {
  console.log('パラメータは ' + arg +' です。1 秒後に結果を返します');
  setTimeout(function() { callback(arg * 2); }, 1000);
}

関数final(値) {
  console.log('完了しました: ', 値);
}

関数ランチャー() {
  while(実行中 < limit && items.length > 0) {
    var item = items.shift();
    非同期(項目、関数(結果) {
      結果をプッシュします。
      実行中--;
      （アイテムの長さ＞0）の場合{
        ランチャー();
      } そうでない場合(実行中 == 0) {
        最終(結果);
      }
    });
    実行中++;
  }
}

ランチャー();

tiny-async-pool、es6-promise-pool、p-limit

function PromiseLimit(funcArray, limit = 5) { // 5つのデータを同時に実行 let i = 0;
  定数結果 = [];
  const 実行 = [];
  定数キュー = 関数() {
    if (i === funcArray.length) の場合、Promise.all(executing) を返します。
    const p = funcArray[i++]();
    結果をpushします。
    const e = p.then(() => execute.splice(executing.indexOf(e), 1));
    実行中.push(e);
    if (実行中の長さ >= 制限) {
      Promise.race(実行中).then( を返す
        () => キュー()、
        e => Promise.reject(e)
      );
    }
    Promise.resolve() を返します。その後 (() => queue());
  };
  キュー（）を返します。その後（）=> Promise.all（結果））;
}

// テストコード const result = [];
(インデックス = 0、インデックス < 10、インデックス++) {
  結果.push(関数() {
    新しい Promise を返します ((resolve, reject) => {
      console.log("start" + インデックス、新しい Date().toLocaleString());
      タイムアウトを設定する(() => {
        解決(インデックス);
        console.log("End" + インデックス、新しいDate().toLocaleString());
      }, parseInt(Math.random() * 10000));
    });
  });
}

PromiseLimit(結果).then(データ => {
  コンソールにログ出力します。
});

// テストコードを変更して、ランダムに失敗または成功するようにします。const result = [];
(インデックス = 0、インデックス < 10、インデックス++) {
  結果.push(関数() {
    新しい Promise を返します ((resolve, reject) => {
      console.log("start" + インデックス、新しい Date().toLocaleString());
      タイムアウトを設定する(() => {
        もし（Math.random() > 0.5）{
          解決(インデックス);
        } それ以外 {
          拒否(インデックス);
        }
        console.log("End" + インデックス、新しいDate().toLocaleString());
      }, parseInt(Math.random() * 1000));
    });
  });
}
PromiseLimit(結果).then(
  データ => {
    console.log("成功", データ);
  },
  データ => {
    console.log("失敗", データ);
  }
);

非同期関数 PromiseAll(promises,batchSize=10) {
 定数結果 = [];
 while(promises.length > 0) {
   const データ = Promise.all(promises.splice(0,batchSize)) を待機します。
   結果.push(...データ);
 }
結果を返します。
}

非同期関数 asyncPool(配列、poolLimit、iteratorFn) {
  定数ret = [];
  const 実行 = [];
  for (配列のconst項目) {
    const p = Promise.resolve().then(() => iteratorFn(item, array));
    ret.push(p);

    プール制限 <= 配列の長さの場合 {
      const e = p.then(() => execute.splice(executing.indexOf(e), 1));
      実行中.push(e);
      実行中の長さ >= poolLimit の場合 {
        Promise.race(実行中) を待機します。
      }
    }
  }
  Promise.all(ret) を返します。
}

const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
asyncPool( [1000, 5000, 3000, 2000], 2,timeout)を返します。その後(結果 => {
    ...
});