Class: Fairy::Controller::MPSameProcessor

Inherits:
MPNewProcessor show all
Defined in:
lib/fairy/controller.rb

Instance Method Summary collapse

Methods inherited from MPNewProcessor

#bind_input, #initialize

Methods inherited from NjobMappingPolicy

#initialize

Constructor Details

This class inherits a constructor from Fairy::Controller::MPNewProcessor

Instance Method Details

#assign_ntask(&block) ⇒ Object 



1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
1059
 
# File 'lib/fairy/controller.rb', line 1039

def assign_ntask(&block)
	pre_bjob.start_export(input_filter)

	pre_bjob.each_export_by(input_filter, self) do |export, opts={}|
#	pre_bjob.each_export_by(input_filter, self) do |export, opts|
# Log::debug(self, "YYYYYYYYYYYYYYY: #{export.class}, #{opts.class}")
#	  opts = {} unless opts
	  # thread を立ち上げるべき
	  # このままでは, 十分に並列性が取れない(for [REQ:#5)]
	  controller.assign_same_processor(target_bjob,
  input_filter.processor) do
	    |processor|
	    # シリアライズに処理されることが前提になっている
	    @export = export
	    @import = target_bjob.create_import(processor)

	    ntask = processor.create_ntask
	    block.call(ntask, @mapper, opts)
	  end
	end
end