javascript Node.js模式：异步控制流

Posted 2021-05-04

const tasks = [];
const concurrency = 2, running = 0, completed = 0, index = 0;
const next = () => {
  while (running < concurrency && index < tasks.length) {
    task = tasks[index++];
    task(() => {
      if (completed = tasks.length) {
        return finish();
      }
      completed++;
      running--;
      next();
    });
    running++;
  }
};
next();

const finish = () => {
  // do something
};