Method: Fairy::SortedQueue1#initialize

Defined in:
lib/fairy/share/port.rb

#initialize(policy, queue_mon = XThread::Monitor.new, queue_cv = queue_mon.new_cond) ⇒ SortedQueue1

Returns a new instance of SortedQueue1.



1611
1612
1613
1614
1615
1616
1617
1618
 
# File 'lib/fairy/share/port.rb', line 1611

def initialize(policy, queue_mon = XThread::Monitor.new, queue_cv = queue_mon.new_cond)
  super

  @threshold = policy[:threshold]
  @threshold ||= CONF.SORTEDQUEUE_THRESHOLD

  @buffers = nil
end