Method init

class/Process.ts:29–66

()

  }

  init(): void {
    if (cluster.isMaster) {
      for (let i = 0; i < this.maxProcess; i += 1) {
        const worker = cluster.fork();
        setLog(worker);
        worker.on('message', arg => {
          if (this.eventListener) {
            this.eventListener.forEach(({ eventName, callback }) => {
              if (arg?.eventName === eventName) {
                logger.info(`event: ${eventName}`);
                callback();
              }
            });
          }
        });
        this.workers.push({
          pid: worker.process.pid,
          worker,
        });
      }
      cluster.on('exit', (worker, code, sign) => {
        const newWorker = cluster.fork();
        setLog(newWorker);
        logger.warning(`process exit whitd code: ${code}, sing: ${sign}, now loading`);
        const newWorkes = this.workers
          .filter(item => worker.process.pid !== item.pid)
          .concat([
            {
              pid: newWorker.process.pid,
              worker: newWorker,
            },
          ]);
        this.workers = newWorkes;
      });
    } else {
      this.callback();
    }
  }
}

interface WorkerFace {