Contents

require 'thread'

class Proco
module Queue
# @private
class SingleQueue < Proco::Queue::Base
  def initialize size, delay
    super
  end

  def push_impl item
    future = Future.new
    @items << [future, item]
    future
  end

  def take_impl
    @items.shift
  end
end
end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
proco-0.0.2	lib/proco/queue/single_queue.rb