kew.rb

class Kew
  require 'socket'

  def initialize
    @in, @out = IO.pipe
  end

  def push(object)
    buf = Marshal.dump(object)
    @out.puts(buf.size)
    @out.write(buf)
  end

  def pop
    size = @in.gets.to_i
    buf = @in.read(size)
    Marshal.load(buf)
  end
end

k = Kew.new

Thread.new do
  loop do
    p k.pop.last
  end
end


3.times do
  k.push [0,1,2, 42]
end

sleep

__END__
42
42
42