安排异步任务的列表（旧学校的nodejs没有承诺）

Question

我想在不使用Promise＆amp;的情况下启动一系列异步任务。异步等待。 我的worfklow是： 。任务1 。任务2 。任务3＆amp; 4（并行）

我尝试了库异步。对于一系列的顺序任务或一系列并行，这是可以的。但是，要实施我的工作，我暂时坚持了。

const async = require('async');
const fs = require('fs');

const readFile1 = (name, callback) => {
        fs.readFile(name, 'utf-8', (err, data) => {
                if (err) {
                        callback(err);
                }
                console.log(data);
                callback(null, data);
        });
}

async.series([
function(callback1) {
        async.series([
                function(callback1) {
                        readFile1('./1.txt', callback1);
                },
                function(callback1) {
                        readFile1('./2.txt', callback1);
                },
        ], function(err, results) {
                console.log('series ', results);
        });
},
function(callback2) {
        async.parallel([
                function(callback2) {
                        readFile1('./3.txt', callback2);
                },
                function(callback2) {
                        readFile1('./4.txt', callback2);
                },
        ], function(err, results) {
                console.log('parallel ', results);
        });
}
]);

目前只有步骤1＆amp; 2执行。您是否有一个想法（使用异步 /等待的更现代的代码样式？

）

Answer 1

您需要在async.series（）之前拨打顶级回调，将继续进行下一步：（

async.series([
  function (callback) {
    async.series(
      [
        function (callback1) {
          readFile1("./1.txt", callback1);
        },
        function (callback2) {
          readFile1("./2.txt", callback2);
        },
      ],
      function (err, results) {
        console.log("series ", results);
        return callback(err, results); // <-- here
      }
    );
  },
  function (callback) {
    async.parallel(
      [
        function (callback1) {
          readFile1("./3.txt", callback1);
        },
        function (callback2) {
          readFile1("./4.txt", callback2);
        },
      ],
      function (err, results) {
        console.log("parallel ", results);
        return callback(err, results); // <-- and here
      }
    );
  },
]);

重命名的回调名称以使情况更加清晰一些）