Method: Fairy::PSort::PPreSort#initialize

Defined in:
lib/fairy/node/p-sort.rb

#initialize(id, ntask, bjob, opts, block_source) ⇒ PPreSort

Returns a new instance of PPreSort.



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/fairy/node/p-sort.rb', line 20

def initialize(id, ntask, bjob, opts, block_source)
  super
  @block_source = block_source

  @exports = []
  def @exports.each_pair(&block)
    each_with_index do |item, idx| 
      block.call(idx, item) if item
    end
  end
  @exports_queue = XThread::Queue.new
  
  @counter = []

  @pvs = nil
  if @opts[:pvs]
    @pvs = @opts[:pvs].dc_deep_copy
  end

  #start_watch_exports
end