Node.js - 在继续代码之前等待多个异步调用完成

所以基本上我有一个 for 循环，其中有一个异步函数。问题是程序只是在循环后继续，我希望它等到循环中调用的所有异步函数都完成后再继续代码。

在我的代码中，“bar”是一个 json 数组，其中包含其他 json 数组。

function write(bla) { // gets called one after another

  for(var url in bla) {
    asyncFunctionCall(url); // Executed about 50 times, it has to run parallel
  }
  // Wait for all called functions to finish before next stuff happens and
  // write gets called again.

}

for(var foo in bar) {
  // Here i parse the json array "foo" which is in the json array "bar"
  write(foo[bla]); // bla is an array of multiple urls.
}

异步函数调用看起来像这样：

var request = require('request');

request(url, function (error, response, body) {
  if(typeof response !== 'undefined') {
    if((response.statusCode >= 400 && response.statusCode <= 451)
    || (response.statusCode >= 500 && response.statusCode <= 511))
      return true;
    return false;
  }
  return false;
});

这里最简单的方法是直接或通过使用 Promiseasync/await句法。在这种情况下，可能直接。

首先，你必须使asyncFunctionCall返回一个承诺。看起来你总是返回一个布尔值，所以在这种情况下我们总是会解决承诺：

function asyncFunctionCall(url) {
  return new Promise(resolve => {
    request(url, function (error, response, body) {
      if(typeof response !== 'undefined') {
        if((response.statusCode >= 400 && response.statusCode <= 451)
        || (response.statusCode >= 500 && response.statusCode <= 511)) {
          resolve(true);
          return;
        }
      }
      resolve(false);
    });
  });
}

然后，建立一系列你的承诺，并使用Promise.all等待所有这些都完成。这些调用运行在平行下:

function write(bla) { // gets called one after another
  const promises = [];
  for(var url in bla) {
    promises.push(asyncFunctionCall(url)); // Executed about 50 times.
  }
  return Promise.all(promises);
}

然后你可以建立一个包含所有承诺的链write所以他们串联运行：

let p = Promise.resolve();
for (const foo in bar) { // <== Notice `const`
  // See "Edit" below
  p = p.then(() => {
    // Here i parse the json object "foo" in the json array "bar"
    // bla is an array of multiple urls.
    return write(foo[bla]));
  });
}

请注意，使用这一点很重要const or let, not var, for foo在那个循环中，因为then回调结束；看这个问题的答案 http://stackoverflow.com/questions/750486/javascript-closure-inside-loops-simple-practical-example为什么const and let使之发挥作用。

每次致电write只有当前一个工作完成后才会进行。

然后等待整个过程完成：

p.then(() => {
  // All done
});

你还没有展示任何东西using布尔值来自write的请求，但它们可以（作为数组）作为承诺的解析值write.

该过程的第二部分，我们称之为write，也可以写成async函数可以使逻辑流程更清晰：

async function doTheWrites() {
  for (const foo in bar) {
    // Here i parse the json object "foo" in the json array "bar"
    // bla is an array of multiple urls.
    await write(foo[bla]);
  }
}

那么整体流程：

doTheWrites().then(() => {
  // All done
});

...或者如果这是also in an async功能：

await doTheWrites();