ProcessPool.js

ProcessPool.js

var fork = require('child_process').fork;

module.exports = ProcessPool;

function ProcessPool(path, size) {
  this.free = [];
  this.waiting = [];
  this._init(path, size || 1);
}

ProcessPool.prototype.getChild = function (cb) {
  var child = this.free.pop();
  if (child) cb(null, child);
  else this.waiting.push(cb);
};

ProcessPool.prototype.recycle = function (child) {
  var waitingCb = this.waiting.pop();
  if (waitingCb) waitingCb(null, child);
  else this.free.push(child);
};

ProcessPool.prototype._init = function (path, size) {
  var i, child;
  for (i = 0; i < size; i++) {
    child = fork(path);
    this.free.push(child);
  }
};