Executor - Producer-Consumer

gistfile1.rb

import java.util.concurrent.Executors

module ProducerConsumer
  def self.do_work
    trap :TERM , -> { Executor.shutdown }
    trap :INT  , -> { Executor.shutdown }

    Executor.execute Producer.new
  end

  module Executor
    def self.execute(job)
      executor.execute job
    end

    def self.shutdown
      $terminate = true
      puts 'Shutting down'
      executor.shutdown
      executor.await_termination 1, TimeUnit::MINUTES
      puts 'Buh Bye'
    end

    def self.executor
      @executor ||= Executors.new_fixed_thread_pool 2
    end
  end

  class Producer
    import java.lang.Runnable

    def run
      puts 'produce'
      Executor.execute Consumer.new unless $terminate
    end
  end

  class Consumer
    import java.lang.Runnable

    def run
      puts 'consume'
      Executor.execute Producer.new  unless $terminate
      sleep 1
    end
  end
end

ProducerConsumer.do_work