Class: PriorityBlockingQueue

Inherits:
BlockingQueue show all
Defined in:
lib/wattics-api-client/blocking_queue.rb

Instance Method Summary collapse

Methods inherited from BlockingQueue

#initialize, #is_empty?, #pop

Constructor Details

This class inherits a constructor from BlockingQueue

Instance Method Details

#<<(x) ⇒ Object 



28
29
30
31
32
33
34
35
 
# File 'lib/wattics-api-client/blocking_queue.rb', line 28

def <<(x)
  @mutex.synchronize do
    @queue << x
    @queue.flatten!
    @queue.sort!
    @received.signal
  end
end