NodeJS native multithreaded code

index.js

const {
  Worker,
  isMainThread,
  parentPort,
  workerData,
  MessageChannel,
} = require("node:worker_threads");
const http = require("node:http");

if (isMainThread) {
  const { port1: httpPort, port2: httpWorkerPort } = new MessageChannel();
  const { port1: computePort, port2: computeWorkerPort } = new MessageChannel();

  new Worker(__filename, {
    workerData: { type: "http", port: httpWorkerPort },
    transferList: [httpWorkerPort],
  });

  new Worker(__filename, {
    workerData: { type: "compute", port: computeWorkerPort },
    transferList: [computeWorkerPort],
  });

  httpPort.on("message", (msg) => console.log(`[HTTP] ${msg}`));
  computePort.on("message", (msg) => console.log(`[COMPUTE] ${msg}`));

  httpPort.postMessage("start");
  computePort.postMessage(25); // Fibonacci(25)
} else {
  const port = workerData.port;

  if (workerData.type === "http") {
    port.on("message", (msg) => {
      if (msg === "start") {
        http
          .createServer((req, res) => {
            res.writeHead(200);
            res.end("Hello from HTTP worker\n");
            port.postMessage(`Handled request: ${req.url}`);
          })
          .listen(3000, () => {
            port.postMessage("Server started on port 3000");
          });
      }
    });
  }

  if (workerData.type === "compute") {
    function fib(n) {
      return n <= 1 ? n : fib(n - 1) + fib(n - 2);
    }

    port.on("message", (n) => {
      const result = fib(n);
      port.postMessage(`Fibonacci(${n}) = ${result}`);
    });
  }
}