micheleriva

<div id="content"> Hi! </div>

<script type="text/javascript">
var content = $("#content");
content.addClass("foo")
</script>

micheleriva

  cluster.on('online', (worker) => log(`Worker ${worker.process.pid} is online`))
  
  cluster.on('exit', (worker, exitCode) => {
    log(`Worker ${worker.process.id} exited with code ${exitCode}`)
    log(`Starting a new worker`)
    cluster.fork()
  }

micheleriva

  let workers = []
  
  for(let i = 0; i < numWorkers; i++) {
    workers.push(cluster.fork())
  }

micheleriva

const cluster    = require('cluster')
const { cpus }   = require('os')
const numWorkers = cpus().length
const isMaster   = cluster.isMaster

if (isMaster) {

  process.stdout.write('I am master!')
  const workers = [...Array(numWorkers)].map(_ => cluster.fork())
  

micheleriva

const cluster  = require('cluster')
const isMaster = cluster.isMaster

micheleriva

const cluster = require('cluster')

micheleriva

const { cpus }   = require('os')
const numWorkers = cpus().length

micheleriva

const cluster  = require('cluster')
const { cpus } = require('os')
const log      = require('./modules/log')

const isMaster   = cluster.isMaster
const numWorkers = cpus().length

if (isMaster) {

  log(`Forking ${numWorkers} workers`)

micheleriva

defmodule Processes do
  alias __MODULE__

  def sendRequest url do
    case HTTPoison.post url, [], [], [timeout: 50_000, recv_timeout: 50_000] do
      {:ok,    %HTTPoison.Response{status_code: 200, headers: headers}} 
          -> IO.inspect headers
      {:error, %HTTPoison.Error{reason: reason}}                  
          -> IO.inspect {:error, reason}
    end

micheleriva

const Koa    = require('koa')
const Router = require('koa-router')
const runJob = require('./modules/job')
const log    = require('./modules/log')
const router = new Router()
const app    = new Koa()

router.get('/', async ctx => ctx.body = `PID ${process.pid} listening here!`)
      .post('/flip', async ctx => {
        const res = await runJob()