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