Class: Proco::Queue::SingleQueue

Inherits:

Object
Base
Proco::Queue::SingleQueue

Defined in:: lib/proco/queue/single_queue.rb

Instance Method Summary collapse

#initialize(size, delay) ⇒ SingleQueue constructor

A new instance of SingleQueue.
#push_impl(item) ⇒ Object
#take_impl ⇒ Object

Methods inherited from Base

#invalidate, #push, #take

Methods included from MT::Base

#broadcast, #do_when, #signal, #synchronize, #try_when, #wait_until

Constructor Details

#initialize(size, delay) ⇒ `SingleQueue`

Returns a new instance of SingleQueue.



7
8
9

# File 'lib/proco/queue/single_queue.rb', line 7

def initialize size, delay
  super
end

Instance Method Details

#push_impl(item) ⇒ `Object`

# File 'lib/proco/queue/single_queue.rb', line 11

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

#take_impl ⇒ `Object`



17
18
19

# File 'lib/proco/queue/single_queue.rb', line 17

def take_impl
  @items.shift
end