function fibonacci(n) {
 if (n == 0 || n == 1) {
  return n;
 } else {
  return fibonacci(n - 1) + fibonacci(n - 2);
 }
}

let startTime = Date.now();
let totalCount = 500;
let completedCount = 0;
let n = 35;

for (let i = 0; i < totalCount; i++) {
 fibonacci(n);
 completedCount++;
 console.log(`process: ${completedCount}/${totalCount}`);
}
console.log("👏 👏 👏 👏 👏 👏 👏 👏 👏 👏");
console.info(`任務(wù)完成，用時(shí): ${Date.now() - startTime}ms`);
console.log("👏 👏 👏 👏 👏 👏 👏 👏 👏 👏");

const cluster = require("cluster");
const numCPUs = require("os").cpus().length;

// 設(shè)置子進(jìn)程執(zhí)行程序
cluster.setupMaster({
 exec: "./worker.js",
 slient: true
});

function run() {
 // 記錄開(kāi)始時(shí)間
 const startTime = Date.now();
 // 總數(shù)
 const totalCount = 500;
 // 當(dāng)前已處理任務(wù)數(shù)
 let completedCount = 0;
 // 任務(wù)生成器
 const fbGenerator = FbGenerator(totalCount);

 if (cluster.isMaster) {
  cluster.on("fork", function(worker) {
   console.log(`[master] : fork worker ${worker.id}`);
  });
  cluster.on("exit", function(worker, code, signal) {
   console.log(`[master] : worker ${worker.id} died`);
  });

  for (let i = 0; i < numCPUs; i++) {
   const worker = cluster.fork();

   // 接收子進(jìn)程數(shù)據(jù)
   worker.on("message", function(msg) {
    // 完成一個(gè)，記錄并打印進(jìn)度
    completedCount++;
    console.log(`process: ${completedCount}/${totalCount}`);

    nextTask(this);
   });

   nextTask(worker);
  }
 } else {
  process.on("message", function(msg) {
   console.log(msg);
  });
 }

 /**
  * 繼續(xù)下一個(gè)任務(wù)
  *
  * @param {ChildProcess} worker 子進(jìn)程對(duì)象，將在此進(jìn)程上執(zhí)行本次任務(wù)
  */
 function nextTask(worker) {
  // 獲取下一個(gè)參數(shù)
  const data = fbGenerator.next();
  // 判斷是否已經(jīng)完成，如果完成則調(diào)用完成函數(shù)，結(jié)束程序
  if (data.done) {
   done();
   return;
  }
  // 否則繼續(xù)任務(wù)
  // 向子進(jìn)程發(fā)送數(shù)據(jù)
  worker.send(data.value);
 }

 /**
  * 完成，當(dāng)所有任務(wù)完成時(shí)調(diào)用該函數(shù)以結(jié)束程序
  */
 function done() {
  if (completedCount >= totalCount) {
   cluster.disconnect();
   console.log("👏 👏 👏 👏 👏 👏 👏 👏 👏 👏");
   console.info(`任務(wù)完成，用時(shí): ${Date.now() - startTime}ms`);
   console.log("👏 👏 👏 👏 👏 👏 👏 👏 👏 👏");
  }
 }
}

/**
 * 生成器
 */
function* FbGenerator(count) {
 var n = 35;
 for (var i = 0; i < count; i++) {
  yield n;
 }
 return;
}

module.exports = {
 run
};

function fibonacci(n) {
 if (n == 0 || n == 1) {
  return n;
 } else {
  return fibonacci(n - 1) + fibonacci(n - 2);
 }
}

// 接收主線(xiàn)程發(fā)送過(guò)來(lái)的任務(wù)，并開(kāi)始查找斐波那契數(shù)
process.on("message", n => {
 var res = fibonacci(n);
 // 查找結(jié)束后通知主線(xiàn)程，以便主線(xiàn)程再度進(jìn)行任務(wù)分配
 process.send(res);
});
入口代碼：cluster.js
// 引入主線(xiàn)程js，并執(zhí)行暴露出來(lái)的run方法
const master = require("./master");
master.run();