Skip to content

Instantly share code, notes, and snippets.

@mbildner
Forked from jpoehls/node-cluster-messaging.js
Created August 14, 2014 19:09
Show Gist options
  • Save mbildner/ce145840e7539562ae8e to your computer and use it in GitHub Desktop.
Save mbildner/ce145840e7539562ae8e to your computer and use it in GitHub Desktop.
var cluster = require('cluster');
if (cluster.isWorker) {
console.log('Worker ' + process.pid + ' has started.');
// Send message to master process.
process.send({msgFromWorker: 'This is from worker ' + process.pid + '.'})
// Receive messages from the master process.
process.on('message', function(msg) {
console.log('Worker ' + process.pid + ' received message from master.', msg);
});
}
if (cluster.isMaster) {
console.log('Master ' + process.pid + ' has started.');
// Fork workers.
for (var i = 0; i < 2; i++) {
var worker = cluster.fork();
// Receive messages from this worker and handle them in the master process.
worker.on('message', function(msg) {
console.log('Master ' + process.pid + ' received message from worker ' + this.pid + '.', msg);
});
// Send a message from the master process to the worker.
worker.send({msgFromMaster: 'This is from master ' + process.pid + ' to worker ' + worker.pid + '.'});
}
// Be notified when worker processes die.
cluster.on('death', function(worker) {
console.log('Worker ' + worker.pid + ' died.');
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment