 
npm install multi-process-worker
sh
npm i multi-process-worker
`
Usage
`js
//master.js for master process
const MPW = require("multi-process-worker");
const option = {
name: "MPW",
workerEntry: 'worker.js',
workerHandler: null,
workerLength: 2,
jobList: [{
name: "job1",
jobTimeout: 5000
}, {
name: "job2"
}, {
name: "error-job"
}, {
name: "job3"
}],
jobTimeout: 10 * 1000,
failFast: false,
workerOption: {
property: "value"
},
onStart: async () => {
console.log('onStart');
},
onMessage: (message) => {
console.log(================ onMessage: ${message});
},
onJobStart: (job) => {
console.log(${job.jobName}: ${job.jobId} - start ${job.name});
},
onJobFinish: (job, o) => {
console.log(${job.jobName}: ${job.jobId} - finish ${job.name}, cost ${job.duration.toLocaleString()}ms);
console.log(o.stats);
},
onFinish: async (o) => {
console.log('onFinish');
if (o.code !== 0) {
console.log(o.name + ': jobs stopped with error: ' + o.code);
}
}
};
const code = await MPW(option);
`
see /test/master.js
`js
//worker.js for child process
process.on('message', async (message) => {
if (message.type === "workerStart") {
let workerOption = message.data;
console.log(workerOption);
process.send({
type: "workerOnline"
});
return;
}
if (message.type === "jobStart") {
var job = message.data;
job.code = await workerHandler(job, process);
process.send({
type: "jobFinish",
data: job
});
return;
}
});
`
see /test/worker.js and /test/handler.js
Test
`
npm run test
`
Master Events
* workerStart
* jobStart
Worker Events
* workerOnline
* workerMessage
* jobFinish
Debug child process with VSCode
`js
{
"version": "0.2.0",
"configurations": [{
"type": "node",
"request": "launch",
"name": "Launch Program",
"autoAttachChildProcesses": true,
"cwd": "${workspaceFolder}/test",
"program": "${workspaceFolder}/test/master.js"
}]
}
``