Run functions in parallel and dynamically alter the parallelization
npm install paraflowRun an asynchronous function on (x) number of items in parallel while allowing
(x) to change at any time.
var paraflow = require('paraflow');
var jobs = [...];
var p = paraflow(3, jobs, workFunction, function finished(err, results){});
// later bump the number of parallel functions allowed.
p.maxFlow(1)
Includes a simpler wrapper if you have an array of functions to call instead of
items. Each function is passed a done(result) callback as the only parameter. When
all the done(result) functions are called, the finished callback is called.
var paraflow = require('paraflow');
var jobs = [function(){}, function(){}]
var p = paraflow(3, jobs, function finished(err, results){});