firebase-queue，工作人员接收任务的速率存在延迟

Question

我像这样将 100 个任务推送到客户端的队列中。

var ref = firebase.database().ref('queue/tasks');
for(var i = 0;i<100;i++){
 ref.push({'foo': 'bar',i:i})
};

在服务器上，我的工人看起来像这样

var queue = new Queue(ref, function(data, progress, resolve, reject){
  console.log(data);
  resolve();
}

问题是完成处理所有任务大约需要 60 秒，这太慢了。有什么方法可以让我的员工更快地接收任务。我想为我的客户端使用队列向服务器发送请求。但是以目前队列的速度，我将无法支持很多并发用户。我希望支持 50k 并发用户。

Answer 1

我注意到的一件事是您没有传入任何选项，您可以设置多个工作人员同时从您的队列中拉取。

options = {
  'numWorkers': 5,
  'sanitize': false,
  'suppressStack': true,
}    
var queue = new Queue(ref, options, function(data, progress, resolve, reject){
  console.log(data);
  resolve();
})

但是，虽然我确实注意到我的机器上的速度有所提高，但我的进程在 1 个工作人员的情况下在大约 9 秒内运行了 100 个，但在 5 个并发工作人员的情况下，它在大约 5 秒内完成。

我使用的是配备 i7 芯片的全新 13 英寸 MacBookPro。

我在设置队列之前使用 performance-now 来执行我的基准测试：

var start = now();

这在队列中的 resolve() 之后

console.log(((now()-start)/1000).toFixed(3));