Method: Fairy::ChunkedPoolQueue#initialize

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

#initialize(policy, queues_mon = XThread::Monitor.new, queues_cv = queues_mon.new_cond) ⇒ ChunkedPoolQueue

multi push threads single pop thread



1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
 
# File 'lib/fairy/share/port.rb', line 1020

def initialize(policy, queues_mon = XThread::Monitor.new, queues_cv = queues_mon.new_cond)
  @policy = policy

  @queue_threshold = CONF.POOLQUEUE_POOL_THRESHOLD
  @queue_max = CONF.POSTQUEUE_MAX_TRANSFER_SIZE

  @push_queue = []
  @push_queue_mutex = Mutex.new
  
  @queues = []
  @queues_mon = queues_mon
  @queues_cv = queues_cv

  @pop_queue = nil
#      @pop_queue_mutex = Mutex.new
end