如何限制Qpromise并发性？

Question

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

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

我需要实现的是一个带有签名的函数

function limitConcurrency(promiseFactory, limit)

我可以这样称呼他

spawnProcess = limitConcurrency(spawnProcess, 5);

// use spawnProcess as usual

我已经开始编写我的版本，但我想知道是否有人有一个简洁的实现，我可以对照它进行检查。

Answer 1

spawnProcess = deferred.gate(spawnProcess, 5);    

Answer 2

这似乎对我有用。

我不确定我是否能简化它。scheduleNextJob中的递归是必需的，因此正在运行

也可作为要点提供。

'use strict';

var Q = require('q');

/**
 * Constructs a function that proxies to promiseFactory
 * limiting the count of promises that can run simultaneously.
 * @param promiseFactory function that returns promises.
 * @param limit how many promises are allowed to be running at the same time.
 * @returns function that returns a promise that eventually proxies to promiseFactory.
 */
function limitConcurrency(promiseFactory, limit) {
  var running = 0,
      semaphore;

  function scheduleNextJob() {
    if (running < limit) {
      running++;
      return Q();
    }

    if (!semaphore) {
      semaphore = Q.defer();
    }

    return semaphore.promise
      .finally(scheduleNextJob);
  }

  function processScheduledJobs() {
    running--;

    if (semaphore && running < limit) {
      semaphore.resolve();
      semaphore = null;
    }
  }

  return function () {
    var args = arguments;

    function runJob() {
      return promiseFactory.apply(this, args);
    }

    return scheduleNextJob()
      .then(runJob)
      .finally(processScheduledJobs);
  };
}

module.exports = {
  limitConcurrency: limitConcurrency
}

Answer 3

我有一个图书馆为你做这件事https://github.com/ForbesLindesay/throat

您可以通过browserify使用它，也可以从brcdn下载独立版本(https://www.brcdn.org/?module=throat

然后（假设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));
  }
}

您可以直接调用though（promiseFactory，limit），但这将返回一个promise-promise，而不是Q-promise。

我也很喜欢使用数组。地图

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