Method: SizedQueue#initialize

Defined in:
lib/thread.rb

#initialize(max) ⇒ SizedQueue

Creates a fixed-length queue with a maximum size of max.

Raises:

  • (ArgumentError) 


252
253
254
255
256
257
258
259
260
 
# File 'lib/thread.rb', line 252

def initialize(max)
  raise ArgumentError, "queue size must be positive" unless max > 0
  @max = max
  @queue_wait = []
  @queue_wait.taint		# enable tainted comunication
  @size_mutex = Mutex.new
  @sem = ConditionVariable.new
  super()
end