class Car
  include Celluloid

  def initialize(start_speed = 10)
    @start_speed = start_speed
    @name = "Audi #{rand(10)}"
  end

  def drive(speed = 80)
    sleep [1, 1.5, 2].sample
    { name: @name, current_speed: speed, start_speed: @start_speed }
  end
end

class HomeController < ApplicationController
  def index
    car = Car.new(70)
    tm = ThreadMan.new(car)

    # Async invocation of "drive" method.
    4.times { tm.submit(:drive, 76) }

    # Check if async tasks are still running.
    puts "\nTasks running: #{tm.tasks_running?}"

    # Get response of first submitted request. This call will block until a response is returned.
    first_response = tm.next_response

    # Get all responses for the submitted requests. Blocking call.
    # Array of responses. Order is the same as the "submit" order.
    all_responses = tm.response

    # NOTE: This is required for GC. Ideally you will call this inside "ensure"
    tm.terminate!

    render json: all_responses
  end
end