如何限制Q许诺并发？

Question

如何编写限制Q许诺并发的方法？

例如，我有一个方法spawnProcess。它返回一个Q承诺。
我希望一次生成的进程不超过5个，但是对于调用代码是透明的。

我需要实现的是带有签名的功能

function limitConcurrency(promiseFactory, limit)

我可以这样称呼

spawnProcess = limitConcurrency(spawnProcess, 5);

// use spawnProcess as usual

我已经开始处理我的版本，但是我想知道是否有人可以检查一个简洁的实现。

Answer 1

我有一个库可以为您做到这一点https://github.com/ForbesLindesay/throat

您可以通过browserify使用它，也可以从brcdn（https://www.brcdn.org/?module=throat&version=latest）下载独立的版本，并将其添加为脚本标记。

然后（假设Promise构造函数在您的环境中已填充或实现），您可以执行以下操作：

//remove this line if using standalone build
var throat = require('throat');

function limitConcurrency(promiseFactory, limit) {
  var fn = throat(promiseFactory, limit);
  return function () {
    return Q(fn.apply(this, arguments));
  }
}

您可以直接致电throat(promiseFactory, limit)，但会返回一个承诺承诺而不是Q承诺。

我也非常喜欢将它与array.map一起使用。

// only allow 3 parallel downloads
var downloadedItems = Q.all(items.map(throat(download, 3)));