rack-rpc-example.ru

require 'rack/rpc'
require 'sucker_punch'
require 'open3'

class Server < Rack::RPC::Server
  @@lock = Mutex.new

  class Worker
    include SuckerPunch::Job
    workers 3

    def perform(input, lock)
      lock.synchronize do
        sleep 5
        Open3.capture2e(input)
      end
    end
  end

  def exec(*args)
    Worker.new.perform(args.join(' '), @@lock)
  end

  rpc 'exec' => :exec
end

use Rack::RPC::Endpoint, Server.new, path: '/'
run -> {}