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
Methods
#
C
D
E
L
N
P
S
Class Public methods
new()

Creates a new queue.

Source: show | on GitHub 

# File lib/thread.rb, line 150
def initialize
  @que = []
  @que.taint          # enable tainted communication
  @num_waiting = 0
  self.taint
  @mutex = Mutex.new
  @cond = ConditionVariable.new
end
Instance Public methods
<<(obj)

Alias of push

Alias for: push
clear()

Removes all objects from the queue.

Source: show | on GitHub 

# File lib/thread.rb, line 229
def clear
  @que.clear
end
deq(non_block=false)

Alias of pop

Alias for: pop
empty?()

Returns true if the queue is empty.

Source: show | on GitHub 

# File lib/thread.rb, line 222
def empty?
  @que.empty?
end
enq(obj)

Alias of push

Alias for: push
length()

Returns the length of the queue.

Also aliased as: size

Source: show | on GitHub 

# File lib/thread.rb, line 236
def length
  @que.length
end
num_waiting()

Returns the number of threads waiting on the queue.

Source: show | on GitHub 

# File lib/thread.rb, line 248
def num_waiting
  @num_waiting
end
pop(non_block=false)

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.

Also aliased as: shift, deq

Source: show | on GitHub 

# File lib/thread.rb, line 186
def pop(non_block=false)
  Thread.handle_interrupt(StandardError => :on_blocking) do
    @mutex.synchronize do
      while true
        if @que.empty?
          if non_block
            raise ThreadError, "queue empty"
          else
            begin
              @num_waiting += 1
              @cond.wait @mutex
            ensure
              @num_waiting -= 1
            end
          end
        else
          return @que.shift
        end
      end
    end
  end
end
push(obj)

Pushes obj to the queue.

Also aliased as: <<, enq

Source: show | on GitHub 

# File lib/thread.rb, line 162
def push(obj)
  Thread.handle_interrupt(StandardError => :on_blocking) do
    @mutex.synchronize do
      @que.push obj
      @cond.signal
    end
  end
end
shift(non_block=false)

Alias of pop

Alias for: pop
size()

Alias of length.

Alias for: length