c4x1

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

//
// ** SharedMemory which is shared among every worker:
//

// dont use `var` 
SharedMemory = {
  // shared data:

c4x1

# clustering
cluster = require "cluster"
process.execPath = "coffee"
os = require("os")
numCPU = os.cpus().length
platform = os.platform()

# logger
winston = require("./lib/utils/logger.coffee")("server.coffee")

c4x1

else {
  // Docs: send a message to the master.
  console.log(`<-- worker${cluster.worker.id} sending message -->`);
  // These two are identical.
  //cluster.worker.send(`message from worker ${cluster.worker.id} (via cluster.worker.send)`);
  process.send(`message from worker ${cluster.worker.id} (via process.send)`);

  // These two are also identical:
  process.on("message", function (message) {
    console.log(`worker[${cluster.worker.id}]: (process.onMessage) '${message}'`);

c4x1

// Copyright Joyent, Inc. and other Node contributors.
//
// Permission is hereby granted, free of charge, to any person obtaining a
// copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to permit
// persons to whom the Software is furnished to do so, subject to the
// following conditions:
//

c4x1

// Require the core node modules.
var chalk = require( "chalk" );
var cluster = require( "cluster" );
var os = require( "os" );

// ----------------------------------------------------------------------------------- //
// ----------------------------------------------------------------------------------- //

// The cluster module in Node.js works by executing the application entry-point
// multiple and sharing the master ports with the worker ports. As such, this code

c4x1

/**
 * -AI-
 * Botのバックエンド(思考を担当)
 *
 * 対話と思考を同じプロセスで行うと、思考時間が長引いたときにストリームから
 * 切断されてしまうので、別々のプロセスで行うようにします
 */

import Othello, { Color } from '../core';

c4x1

import sane from 'sane';
import { resolve as resolvePath } from 'path';
import { spawn, fork } from 'child_process';
import { existsSync as fileExists} from 'fs';
import {
  red, green, yellow, blue,
  magenta, cyan, white, gray
} from 'chalk';

process.env.PATH += ':./node_modules/.bin';

c4x1

import { Request, Response, Router } from "express";
import * as fs from "fs";
import * as child from "child_process";

export class HeavyController {
    public router: Router = Router();

    constructor() {
      this.router.get("/", (req: Request, res: Response) => {
        const copute = child.fork("./src/controllers/compute.ts");

c4x1

 var cluster = require('cluster'),
        http = require('http'),
        os = require('os'),
        
        /*
         * ClusterServer object
         * 
         * We start multi-threaded server instances by passing the server object
         * to ClusterServer.start(server, port).
         *

c4x1

import { ChildProcess, fork } from 'child_process';
import config from '../config';

const { requestLimit } = config;

interface forkResponse {
    kill: boolean;
    string?: string;
}