在Javascript中等待一些异步任务完成的最简单方法？

javascript asynchronous node.js mongoose synchronous

2022-08-30 05:36:56

我想删除一些mongodb集合，但这是一个异步任务。代码将是：

var mongoose = require('mongoose');

mongoose.connect('mongo://localhost/xxx');

var conn = mongoose.connection;

['aaa','bbb','ccc'].forEach(function(name){
    conn.collection(name).drop(function(err) {
        console.log('dropped');
    });
});
console.log('all dropped');

控制台显示：

all dropped
dropped
dropped
dropped

确保在所有馆藏都被删除后进行打印的最简单方法是什么？任何第三方都可以用来简化代码。all dropped

答案 1

使用承诺。

var mongoose = require('mongoose');

mongoose.connect('your MongoDB connection string');
var conn = mongoose.connection;

var promises = ['aaa', 'bbb', 'ccc'].map(function(name) {
  return new Promise(function(resolve, reject) {
    var collection = conn.collection(name);
    collection.drop(function(err) {
      if (err) { return reject(err); }
      console.log('dropped ' + name);
      resolve();
    });
  });
});

Promise.all(promises)
.then(function() { console.log('all dropped)'); })
.catch(console.error);

这会删除每个集合，在每个集合之后打印“丢弃”，然后在完成后打印“全部删除”。如果发生错误，则会将其显示为。stderr

之前的答案（这早于 Node 对 Promises 的原生支持）：

使用Q承诺或蓝鸟承诺。

使用 Q：

var Q = require('q');
var mongoose = require('mongoose');

mongoose.connect('your MongoDB connection string');
var conn = mongoose.connection;

var promises = ['aaa','bbb','ccc'].map(function(name){
    var collection = conn.collection(name);
    return Q.ninvoke(collection, 'drop')
      .then(function() { console.log('dropped ' + name); });
});

Q.all(promises)
.then(function() { console.log('all dropped'); })
.fail(console.error);

与蓝鸟：

var Promise = require('bluebird');
var mongoose = Promise.promisifyAll(require('mongoose'));

mongoose.connect('your MongoDB connection string');
var conn = mongoose.connection;

var promises = ['aaa', 'bbb', 'ccc'].map(function(name) {
  return conn.collection(name).dropAsync().then(function() {
    console.log('dropped ' + name);
  });
});

Promise.all(promises)
.then(function() { console.log('all dropped'); })
.error(console.error);

答案 2

我看到你正在使用，所以你正在谈论服务器端JavaScript。在这种情况下，我建议查看异步模块并使用.您会发现此模块非常有用 - 它的开发是为了解决您正在努力解决的问题。您的代码可能如下所示mongooseasync.parallel(...)

var async = require('async');

var calls = [];

['aaa','bbb','ccc'].forEach(function(name){
    calls.push(function(callback) {
        conn.collection(name).drop(function(err) {
            if (err)
                return callback(err);
            console.log('dropped');
            callback(null, name);
        });
    }
)});

async.parallel(calls, function(err, result) {
    /* this code will run after all calls finished the job or
       when any of the calls passes an error */
    if (err)
        return console.log(err);
    console.log(result);
});