asyncjs回调未被执行

Question

我正在尝试合并来自两个JSON文件（客户列表）的数据，然后创建与客户一样多的任务，稍后将通过async.js执行

为了让所有任务数组都满了，我用一个承诺来控制forEach的结束：

var parsePromise = new Promise(function (resolve, reject) {
mongoDB.MongoClient.connect(dbURL, (error, db) => {
        originalData.forEach(function (element, index) {
            var restoredCustomer = Object.assign(element, backupData[index]);

            tasksArray.push((function (db, element) {
                return function () {
                    db.collection('customers').insert(element, function (error) {
                        if (error) {
                            console.error("Error: ", error);
                        }
                    })
                }
            })(db, restoredCustomer));

            forEachCounter--;
            if (forEachCounter === 0) {
                resolve(tasksArray);
            }
        });
    });
});

然后，当promise结束时，我执行async.js parallel方法：

parsePromise.then(function (tasksArray) {
    async.parallel(tasksArray, (err, results) => {
        console.log("Operation completed successfully: ", results);
    })
})

奇怪的是代码工作正常，并且插件正在MongoDB上完成，但是，console.log("Operation completed successfully: ", results);回调中放置的parallel从未显示过。

Answer 1

试试这个

var parsePromise = new Promise(function (resolve, reject) {
mongoDB.MongoClient.connect(dbURL, (error, db) => {
        originalData.forEach(function (element, index) {
            var restoredCustomer = Object.assign(element, backupData[index]);
             tasksArray.push(function(cb){
                  db.collection('customers').insert(restoredCustomer, function (error) {
                        if (error) return cb(err);
                        cb();
                    })
             });

            forEachCounter--;
            if (forEachCounter === 0) {
                resolve(tasksArray);
            }
        });
    });
});

根据异步js文档，在async.js中并行函数的https://caolan.github.io/async/global.html任务参数必须是AsyncFunction。 AsyncFunction需要具有最终参数，这是一个回调。回调的结构遵循函数标准（err，args）。

您也可以尝试将代码简化为：

new Promise((resolve, reject) => {
  mongoDB.MongoClient.connect(dbURL, (error, db) => {
        if (error) return reject(error);
        resolve(db);
  });
}).then(db => {
  var tasksArray = [];
  for (let i = 0; i != originalData.length; ++i){
    var restoredCustomer = Object.assign(originalData[i], backupData[index]);
    tasksArray.push(function(cb){
      db.collection('customers').insert(restoredCustomer, function (error) {
        if (error) return cb(err);
        cb();
      })
    });
  }

  return new Promise((resolve, reject) => {
    async.parallel(tasksArray, (err, results) => {
        if (err) return reject(err);
        resolve(results)
    })
  })
})