Method: XThread::RBQueue#initialize

Defined in:
lib/xthread.rb

#initialize ⇒ RBQueue

Returns a new instance of RBQueue.



59
60
61
62
63
64
65
 
# File 'lib/xthread.rb', line 59

def initialize
  @que = []
  @que.taint    # enable tainted comunication
  self.taint
  @mutex = Mutex.new
  @cond = XThread::ConditionVariable.new
end