Class: Fairy::Controller::MPNewProcessorN

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 



1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
 
# File 'lib/fairy/controller.rb', line 1016

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|
#   opts = {} unless opts
    # thread を立ち上げるべき
    # このままでは, 十分に並列性が取れない(for [REQ:#5)]

    controller.assign_new_processor_n(target_bjob, pre_bjob) do 
      |processor|
      # シリアライズに処理されることが前提になっている
      @export = export
      @import = target_bjob.create_import(processor)
      ntask = processor.create_ntask
      block.call(ntask, @mapper, opts)
    end
  end
end