我有下面的代码，我想在 Myurl 的每次迭代之间放置一个 setTimeout。有许多类，每个类都包含许多元素。

//Some calculations before...
var i = 0;
async.whilst(
function () {
    return i <= thefooz.length - 1;
},
function (innerCallback) {

    //Some calculations where I get classes array.

    async.forEachOfSeries(classes, function (Myurl, m, eachDone) {
        // Here I want a delay
        async.waterfall([
            function (next) {
                connection.query(
                    'SELECT * FROM mydata WHERE UrlLink=? LIMIT 1', [Myurl],
                    next
                );
            },
            function (results, fields, next) {
                if (results.length !== 0) {
                    console.log("Already Present");
                    return next();
                }
                console.log("New Thing!");
                request(options2, function (err, resp, body) {
                    if (!err && resp.statusCode == 200) {
                        var $ = cheerio.load(body);
                        //Some calculations, where I get AllLinks.
                        var post = {
                            ThisUrl: AllLinks[0],
                            Time: AllLinks[1],
                        };
                        var query = connection.query('Insert INTO mydata Set ?', post, next);
                    };
                });
            }
        ], eachDone);

    }, function (err) {
        if (err) throw err;
    });
    setTimeout(function () {
        i++;
        innerCallback();
        console.log("Done");
    }, 20000);

    //Some calculations after...

那么如何在 async.waterfall 中的每个 Myurl 之间设置延迟？假设我要延迟 5 秒。我设法设置 setTimeout 之间 每个 async.whilst 迭代，但不是在每个 async.forEachOfSeries 迭代之间。它根本不等待，而是继续循环，直到每个 async.forEachOfSeries 完成，然后调用 async.whilst setTimeout。

编辑: 队列解决方案不起作用。该解决方案似乎只是转到下一页，下一页等等，而不输出到我的数据库。当然，我可以以错误的方式应用它，但我确实尝试完全按照示例所述进行操作。

最佳答案

首先我们必须实现一个简单的队列

队列

function Queue() {
  var obj = {};  
  var queue = [];
  var _delay;
  
  function next() {
    // If queue is empty stops execution
    if(queue.length == 0) return;
    
    // Prepare next call to next
    setTimeout(next, _delay);
    // Take out an element from the queue and execute it.
    (queue.shift())();          
  }
  
  // Add a new function to the queue
  obj.add = function (myFunc) {
    queue.push(myFunc);
  };
  
  // Start the queue execution passing the delay between each call
  obj.run = function(delay) {
    _delay = delay;
    
    // call next function
    next();
  }
  
  return obj;
  
}

然后我们在代码里面使用它

// create the queue
var myQueue = Queue();

async.forEachOfSeries(classes, function (Myurl, m, eachDone) {
  // Add the function to the queue
  myQueue.add(executeWaterfall.bind(this));
}, function (err) {
  if (err) throw err;
});

// Start the queue with 5 second delay
myQueue.run(5000);

function executeWaterfall() {
  async.waterfall([
    function (next) {
      connection.query(
        'SELECT * FROM mydata WHERE UrlLink=? LIMIT 1', [Myurl],
        next
      );
    },
    function (results, fields, next) {
      if (results.length !== 0) {
        console.log("Already Present");
        return next();
      }
      console.log("New Thing!");
      request(options2, function (err, resp, body) {
        if (!err && resp.statusCode == 200) {
          var $ = cheerio.load(body);
          //Some calculations, where I get AllLinks.
          var post = {
            ThisUrl: AllLinks[0],
            Time: AllLinks[1],
          };
          var query = connection.query('Insert INTO mydata Set ?', post, next);
        };
      });
    }
  ], eachDone);
}

这远非最佳，因为无论如何你都陷入了所谓的末日金字塔

奖金

末日金字塔

当使用普通回调连续处理异步操作时，您最终会在彼此之间嵌套调用；这种嵌套会产生更多的缩进，形成一个金字塔(指向右侧)，因此得名“末日金字塔”。

解决方案

在这种情况下，最好使用一些 promise 模式来将您的代码从厄运金字塔中拯救出来并促进此类问题的解决。

• More Info
• PromiseJS

关于javascript - setTimeout 在迭代的迭代内，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30750051/