// cluster.js — primary가 코어 수만큼 worker를 fork한다
import cluster from "node:cluster";
import http from "node:http";
import { availableParallelism } from "node:os";

if (cluster.isPrimary) {
  const numCPUs = availableParallelism();
  console.log(`Primary ${process.pid}: ${numCPUs}개 worker 시작`);

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

  cluster.on("exit", (worker, code, signal) => {
    console.warn(`Worker ${worker.process.pid} 종료 (${signal ?? code}) — 재시작`);
    cluster.fork(); // 비정상 종료 시 즉시 교체
  });
} else {
  // 각 worker 프로세스가 독립적으로 HTTP 서버를 실행한다
  http
    .createServer((req, res) => {
      res.end(`Worker ${process.pid}이 처리\n`);
    })
    .listen(3000);

  console.log(`Worker ${process.pid} 시작`);
}

import { availableParallelism } from "node:os";

// CPU 코어 수에 맞춰 worker를 생성하는 것이 일반적인 출발점이다
// (I/O 위주 서버는 코어 수 × 1~2, CPU 위주는 코어 수와 동일하게)
const workers = availableParallelism();
console.log(`이 머신에서 최적 worker 수: ${workers}`);

import cluster from "node:cluster";

// 라운드로빈 스케줄링 명시 (Linux 기본값 — 명시하지 않아도 동작한다)
cluster.schedulingPolicy = cluster.SCHED_RR;

// OS 스케줄링으로 전환 (Windows 기본값)
// cluster.schedulingPolicy = cluster.SCHED_NONE;

if (cluster.isPrimary) {
  cluster.fork();
  cluster.fork();

  // primary에서 worker에게 메시지 전송
  for (const worker of Object.values(cluster.workers)) {
    worker.send({ type: "config", value: "production" });
  }
}

// 선택 기준 요약
//
// worker_threads 사용 시:
//   - CPU 집약 계산 (이미지 처리, 암호화)
//   - SharedArrayBuffer로 대용량 데이터 공유
//   - 스레드 간 빠른 메시지 교환
//
// cluster 사용 시:
//   - HTTP/TCP 서버의 수평 확장
//   - 프로세스 완전 격리 (메모리 누수 방지)
//   - 무중단 배포 (old worker를 종료하며 new worker로 교체)

import { Worker } from "node:worker_threads";
import cluster from "node:cluster";

// 두 기술을 함께 사용하는 패턴:
// cluster로 프로세스를 나누고, 각 worker 내에서 worker_threads로 CPU 작업 처리
if (cluster.isPrimary) {
  cluster.fork();
} else {
  const cpuWorker = new Worker("./compute.js", { workerData: { n: 1e7 } });
  cpuWorker.on("message", (result) => console.log("계산 결과:", result));
}

import cluster from "node:cluster";

const MAX_RESTARTS = 10;
const RESTART_WINDOW_MS = 60_000; // 1분
const restartTimes = [];

if (cluster.isPrimary) {
  cluster.fork();

  cluster.on("exit", (worker, code, signal) => {
    const isIntentional = worker.exitedAfterDisconnect;
    if (isIntentional) return; // 의도적 종료 (무중단 배포 등)

    // 재시작 루프 감지
    const now = Date.now();
    restartTimes.push(now);
    const recent = restartTimes.filter((t) => now - t < RESTART_WINDOW_MS);
    restartTimes.length = 0;
    restartTimes.push(...recent);

    if (recent.length >= MAX_RESTARTS) {
      console.error(`1분 내 ${MAX_RESTARTS}회 재시작 — 치명적 오류 가능성. 중단.`);
      process.exit(1);
    }

    console.warn(`Worker ${worker.process.pid} 비정상 종료 — 재시작 (${recent.length}/${MAX_RESTARTS})`);
    cluster.fork();
  });
}