Ruby Elevator

Elevator

#!/usr/bin/ruby
# elevator.rb

require 'drb/drb'

requests = []
DRb.start_service('druby://localhost:9999', requests)

tick = 0
loop do
  puts "Tick: #{tick}"
  req = requests.shift
  puts "Someone on floor #{req[0]} requested to go to floor #{req[1]}" if req

  tick += 1
  sleep 1
end

#------------------------------

#!/usr/bin/ruby

require 'drb/drb'

class People
  attr_reader :queue

  MAX_FLOOR = 10

  def connect
    DRb.start_service
    @queue = DRbObject.new_with_uri('druby://localhost:9999')
  end

  def reconnect
    puts 'Connection failure. Retrying...'
    connect
  end

  def start_request_loop
    connect

    loop do
      floors = (0..MAX_FLOOR).to_a
      start, dest = floors.sample(2)

      queue.push([start, dest])
      p [start, dest]

      sleep rand(0.0..10.0)
    end
  rescue DRb::DRbConnError
    reconnect
    sleep 2
    retry
  end
end

people = People.new
people.start_request_loop