javascript - Underscore.js throttle 不起作用

Question

目标

找出我的代码出了什么问题，或者 underscore.js throttle 是否正常工作。

背景

我的文件中有一个巨大的邮政编码列表，我正在读取这些代码并将它们粘贴到控制台上。

我正在尝试使用Underscore.js throttle() function ，但是我的代码在两次运行后停止(即使我有几十次)，并且其余的值永远不会打印。

代码

我的代码位于一个非常简单的 NodeJS 项目中。我创建了一个MCVE我面临的情况:

"use strict";

//requiremetns
let fs = require('fs');
let readLine = require('readline');
let _ = require('underscore');

//constants
const INPUT_FILE = 'dataset.txt';
const RADIX_CONVERSATION = 10;
const THROTTLE_DELAY = 500;

let init = function() {

  let lineReader = readLine.createInterface({
    input: fs.createReadStream(INPUT_FILE),
    output: process.stdout,
    terminal: false
  });

  let throttledRequestFn = _.throttle(requestFn, THROTTLE_DELAY);

  lineReader.on('line', function(line) {
    line = line.trim();

    if (_.isNaN(parseInt(line, RADIX_CONVERSATION))) {
      //Do some stuff
    }
    else {
      throttledRequestFn('mahCountry', line);
    }
  });
};

let requestFn = function(country, postalCode){
  console.log('request for ' + country + ' and postal ' + postalCode + ' done');
  return false;
};


init();

在这里，我首先从读取文件开始，一次一行。然后，如果我正在读取的行是数字，我会打印一些内容，否则什么也不打印。

以下是测试文件:

Vietnam
000000  
100000
160000  
170000  
180000  
200000
220000
230000
240000  
250000  
260000
270000
280000
290000  
300000  
310000  
320000  
330000
350000
360000
380000
390000
400000  
410000  
420000
430000  
440000
460000  
480000
510000
520000
530000
550000
560000
570000  
580000  
590000
600000
620000
630000
640000  
650000  
660000
670000
700000
790000  
800000
810000  
820000
830000
840000  
850000
860000  
870000  
880000  
890000  
900000
910000
920000
930000  
940000
950000
960000
970000

问题

在我看来，我的代码应该每秒发出 2 个请求，每个请求之间有 500 毫秒的延迟。它应该打印测试文件中的所有代码。 但是，我从未见过任何超过第二个值的东西!为什么会发生这种情况？

Answer 1

throttle 功能正在按预期工作。来自 documentation :

Useful for rate-limiting events that occur faster than you can keep up with.

这意味着您的包装函数的调用频率可能会比您想要的少。

您真正想要的可能是某种队列。 Underscore 没有提供，但异步库提供了:http://caolan.github.io/async/docs.html#.queue

let fs = require('fs');
let readLine = require('readline');
let _ = require('async');
// import the async library
let async = require('async');

const INPUT_FILE = 'dataset.txt';
const RADIX_CONVERSATION = 10;

// create the queue
var q = async.queue(function(task, callback) {
  // make sure the queue task calls the callback only after the THROTTLE_DELAY
  setTimeout(function () {
    requestFn(task.country, task.postalCode);
    callback();
  }, THROTTLE_DELAY);

}, 1)

q.drain = function () {
  console.log('all items have been processed');
};

let init = function () {
  let lineReader = readLine.createInterface({
    input: fs.createReadStream(INPUT_FILE),
    output: process.stdout,
    terminal: false
  });

  lineReader.on('line', function(line) {
    line = line.trim();

    if (_.isNaN(parseInt(line, RADIX_CONVERSATION))) {
      // Do some stuff
    }
    else {
      // Add the line to the Queue, to be executed later
      q.push({country: 'mahCountry', postalCode: line});
    }
  });
};

let requestFn = function(country, postalCode){
  console.log('request for ' + country + ' and postal ' + postalCode + ' done');
  return false;
};

init();

注意在处理队列中元素的函数中使用setTimeout。这样，您仍然每 500 毫秒仅发出一个请求，但可以保证发出所有请求。