在 Node.js 中等待多个回调的惯用方法

假设您需要执行一些依赖于某些临时文件的操作。自从 我们这里讨论的是 Node，这些操作显然是异步的。 等待所有操作完成的惯用方法是什么 知道什么时候可以删除临时文件吗？

这是一些显示我想要做什么的代码：

do_something(tmp_file_name, function(err) {});
do_something_other(tmp_file_name, function(err) {});
fs.unlink(tmp_file_name);

但是如果我这样写，第三个调用可以在前两个调用之前执行 有机会使用该文件。我需要某种方法来保证前两个 在不嵌套地继续之前调用已经完成（调用它们的回调） 调用（并在实践中使它们同步）。

我考虑过在回调上使用事件发射器并注册一个计数器 作为接收者。计数器将接收已完成的事件并计算有多少 行动仍悬而未决。当最后一个完成后，它将删除 文件。但存在竞争条件的风险，我不确定这是不是 通常这些东西是如何完成的。

Node 人如何解决这种问题呢？

Update:

现在我建议看一下：

• Promises

  Promise 对象用于延迟和异步计算。 Promise 代表尚未完成但已完成的操作 预计在未来。

  一个流行的 Promise 库是bluebird。 A建议看看为什么要承诺.

  你应该使用承诺来改变这个：

  fs.readFile("file.json", function (err, val) {
      if (err) {
          console.error("unable to read file");
      }
      else {
          try {
              val = JSON.parse(val);
              console.log(val.success);
          }
          catch (e) {
              console.error("invalid json in file");
          }
      }
  });
  

  进入这个：

  fs.readFileAsync("file.json").then(JSON.parse).then(function (val) {
      console.log(val.success);
  })
  .catch(SyntaxError, function (e) {
      console.error("invalid json in file");
  })
  .catch(function (e) {
      console.error("unable to read file");
  });
  

• 发电机：例如通过co.

  Nodejs 和浏览器基于生成器的控制流优点， 使用 Promise，让您以一种漂亮的方式编写非阻塞代码。

  var co = require('co');
  
  co(function *(){
    // yield any promise
    var result = yield Promise.resolve(true);
  }).catch(onerror);
  
  co(function *(){
    // resolve multiple promises in parallel
    var a = Promise.resolve(1);
    var b = Promise.resolve(2);
    var c = Promise.resolve(3);
    var res = yield [a, b, c];
    console.log(res);
    // => [1, 2, 3]
  }).catch(onerror);
  
  // errors can be try/catched
  co(function *(){
    try {
      yield Promise.reject(new Error('boom'));
    } catch (err) {
      console.error(err.message); // "boom"
   }
  }).catch(onerror);
  
  function onerror(err) {
    // log any uncaught errors
    // co will not throw any errors you do not handle!!!
    // HANDLE ALL YOUR ERRORS!!!
    console.error(err.stack);
  }
  

如果我理解正确的话，我想你应该看看非常好的async图书馆。你应该特别看看series。只是 github 页面片段的副本：

async.series([
    function(callback){
        // do some stuff ...
        callback(null, 'one');
    },
    function(callback){
        // do some more stuff ...
        callback(null, 'two');
    },
],
// optional callback
function(err, results){
    // results is now equal to ['one', 'two']
});


// an example using an object instead of an array
async.series({
    one: function(callback){
        setTimeout(function(){
            callback(null, 1);
        }, 200);
    },
    two: function(callback){
        setTimeout(function(){
            callback(null, 2);
        }, 100);
    },
},
function(err, results) {
    // results is now equals to: {one: 1, two: 2}
});

另外，这个库还可以在浏览器中运行。