a.rb

#!/usr/bin/env ruby
# -*- coding: utf-8 -*

require_relative "../ixia"

def compile(job)
end

ps = (0..$master.processor_count).map do |i|
  Place.new do
    loop do
      case job = $ref.put([:get_job]).get
      when :done
        break
      else
        job = compile(job)
        msg = [:job_finished, job]
        $ref.put(msg)
      end
    end
  end
end

job_queue = Queue.new

ps.sync_each do |p|
  loop do
    m = p.get
    case m[0]
    when :get_job
      begin
        job = job_queue.pop(non_block=true)
      rescue
        p.put(:done)
        break
      end
      p.put(job)
    when :job_finished
      job = m[1]
    end
  end
end