node.js中 cluster 模块和 worker_threads 模块

1. cluster 模块

const cluster = require('cluster');

if (cluster.isMaster) {
  // 主进程代码
  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }
} else {
  // 子进程代码
  // 创建 Nest.js 应用程序实例等
}

2. worker_threads 模块

const { Worker, isMainThread, parentPort } = require('worker_threads');

if (isMainThread) {
  // 主线程代码
  const worker = new Worker('worker.js');
  worker.on('message', (message) => {
    console.log('Received message from worker:', message);
  });
  worker.postMessage('Hello from main thread!');
} else {
  // 工作线程代码
  parentPort.on('message', (message) => {
    console.log('Received message from main thread:', message);
    parentPort.postMessage('Hello from worker thread!');
  });
}

• cluster 模块适用于需要在多个 CPU 核心之间分布负载的情况，可以充分利用多核 CPU，并通过主从模式来管理多个子进程。

• worker_threads 模块适用于在单个 CPU 核心内执行并行任务，可以提高并行处理能力，但需要注意线程之间的数据共享和同步问题。