Object
This class provides a way to synchronize communication between threads.
Example:
require 'thread' queue = Queue.new producer = Thread.new do 5.times do |i| sleep rand(i) # simulate expense queue << i puts "#{i} produced" end end consumer = Thread.new do 5.times do |i| value = queue.pop sleep rand(i/2) # simulate expense puts "consumed #{value}" end end consumer.join
Removes all objects from the queue.
# File thread.rb, line 340 def clear @que.clear end
Returns true
is the queue is empty.
# File thread.rb, line 333 def empty? @que.empty? end
Returns the length of the queue.
# File thread.rb, line 347 def length @que.length end
Returns the number of threads waiting on the queue.
# File thread.rb, line 359 def num_waiting @waiting.size end
Retrieves data from the queue. If the queue is empty, the calling thread
is suspended until data is pushed onto the queue. If
non_block
is true, the thread isn't suspended, and an
exception is raised.
# File thread.rb, line 309 def pop(non_block=false) while (Thread.critical = true; @que.empty?) raise ThreadError, "queue empty" if non_block @waiting.push Thread.current Thread.stop end @que.shift ensure Thread.critical = false end