javascript - 如何限制 Q Promise 并发？

Question

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

例如，我有一个方法 spawnProcess。它返回一个 Q promise 。
我希望一次生成的进程不超过 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) 但这会返回 promise promise 而不是 Q promise 。

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

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