5 examples of 'cluster fork' in JavaScript

13
function fork(CLUSTER_ROLE) {
14
  cluster.fork({ CLUSTER_ROLE })
15
  .on('online', () => {
16
    _.dev(() => console.warn(`worker ${CLUSTER_ROLE} is online.`));
17
  })
18
  .on('exit', (code, signal) => {
19
    _.dev(() => console.warn(`Worker ${CLUSTER_ROLE} exited with code ${code} and signal ${signal}.`));
20
    fork(CLUSTER_ROLE);
21
  });
22
}

165
_fork() {
166
    return cluster.fork()
167
}

104
function forkWorker() {
105
106
  var worker = cluster.fork();
107
108
  worker.on('message', function (msg) {
109
110
    if (msg.cmd) {
111
112
      if (msg.cmd == 'workerStarted') {
113
114
        runningWorkers++;
115
116
        if (runningWorkers === parseInt(totalWorkers)) {
117
          console.log("Calipso configured for: ".green + (global.process.env.NODE_ENV || 'development') + " environment.".green);
118
          console.log("Calipso server running ".green + runningWorkers + " workers, listening on port: ".green + port);
119
        }
120
121
      }
122
123
    }
124
125
  });
126
127
}

14
function fork(offset, execArgv) {
15
  if (execArgv)
16
    cluster.setupMaster({execArgv});
17
18
  const check = common.mustCall(checkExitCode);
19
  cluster.fork({portSet: debuggerPort + offset}).on('exit', check);
20
}

46
fork() {
47
    const worker = new ForkMock();
48
49
    worker.on(FORK_EVENTS.send, message => {
50
        this.workers[message.data.filename] = worker;
51
52
        this.emit(CLUSTER_EVENTS.internalMessage, message);
53
    });
54
55
    this.once(CLUSTER_EVENTS.fork, () => worker.emit(FORK_EVENTS.online));
56
57
    process.nextTick(() => this.emit(CLUSTER_EVENTS.fork, worker));
58
59
    return worker;
60
}