Cleaned up cluster_app.js
This commit is contained in:
@ -1,27 +1,15 @@
|
|||||||
/**
|
|
||||||
* Module dependencies.
|
|
||||||
*/
|
|
||||||
|
|
||||||
var os = require('os');
|
var os = require('os');
|
||||||
var cluster = require('cluster');
|
var cluster = require('cluster');
|
||||||
|
|
||||||
/**
|
|
||||||
* Cluster setup.
|
|
||||||
*/
|
|
||||||
|
|
||||||
// Setup the cluster to use app.js
|
|
||||||
cluster.setupMaster({
|
cluster.setupMaster({
|
||||||
exec: 'app.js'
|
exec: 'app.js'
|
||||||
});
|
});
|
||||||
|
|
||||||
// Listen for dying workers
|
|
||||||
cluster.on('exit', function(worker) {
|
cluster.on('exit', function(worker) {
|
||||||
console.log('Worker ' + worker.id + ' died');
|
console.log('worker ' + worker.id + ' died');
|
||||||
// Replace the dead worker
|
|
||||||
cluster.fork();
|
cluster.fork();
|
||||||
});
|
});
|
||||||
|
|
||||||
// Fork a worker for each available CPU
|
|
||||||
for (var i = 0; i < os.cpus().length; i++) {
|
for (var i = 0; i < os.cpus().length; i++) {
|
||||||
cluster.fork();
|
cluster.fork();
|
||||||
}
|
}
|
Reference in New Issue
Block a user