Method: Fairy::FileBufferdQueue#initialize

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

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

Returns a new instance of FileBufferdQueue.



1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
 
# File 'lib/fairy/share/port.rb', line 1141

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

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

  @push_queue = []
  @pop_queue = @push_queue
  @buffers_queue = nil

  @queue_mon = queue_mon
  @queue_cv = queue_cv
end