"I am Legion, for we are many." Raise a legion of Node worker processes to do your bidding.
"I am Legion, for we are many." — Mark, 5:9
Raise a legion of Node worker child processes to do your bidding.
If your tasks are asynchronous and creating child processes is too expensive
for your taste, check out the
chain-gang module as a possible alternative.
npm install legion
var taskData =purpose: 'JSON-serializable data you want to provide to your Workers';var Legion = ;var legion =taskScript: requiresilent: falsemaxWorkers: 100;
You just use
process.exit in your task script
to communicate with the Legion parent process. No Legion-specific hooks or
consumptions are required.
If your task doesn't require any "taskData" at runtime, then you can choose to
NOT listen for the
start event and just get started, e.g.:
var defaultConfig =// The number of workers.// Default: `require('os').cpus().length` (1 per CPU)maxWorkers: oslength// Should the initial creation of workers be staggered?// Default: `false`.stagger: false// The number of milliseconds to use as a staggered start time for workers.// Only relevant if `stagger` is set to `true`.// Default: `5000` (5 seconds).staggeredStart: 5000// When one worker finishes, should a new worker "take the next shift"?// Note that if `stagger` is set to `true`, reinforcements will continue to// honor the `staggeredStart` delay.// Default: `true`.continuous: true// The number of milliseconds to use as the maximum allowed run time for a// single execution of the `mission`. When the limit is reached, the soldier will// be forcibly killed if the `mission` has not been completed.// Default: `null` (infinite time)maxWorkerTime: null// The number of milliseconds to use as the maximum allowed run time for the// entire process. If you have reinforceing workers, they will continue to work// until this limit is reached, and then the Legion will kill off all of its// subordinates.// Default: `null` (infinite time)maxTime: null// The actual work to do. This MUST be set to an existing file path.// Default: `null`.taskScript: null// Suppress all stdio from Worker processes// Default: `true`silent: true;