Class: Fairy::Controller::MPNewProcessor

Inherits:

NjobMappingPolicy

• Object
• NjobMappingPolicy
• Fairy::Controller::MPNewProcessor

Defined in:

lib/fairy/controller.rb

Overview

必要ない?

class MPSameProcessorObj < NjobMappingPolicy
end

Direct Known Subclasses

MPNewProcessorN, MPSameProcessor

Instance Method Summary

• #assign_ntask(&block) ⇒ Object
• #bind_input(njob) ⇒ Object
• #initialize(mapper) ⇒ MPNewProcessor constructor

  A new instance of MPNewProcessor.

Constructor Details

#initialize(mapper) ⇒ MPNewProcessor

Returns a new instance of MPNewProcessor.

# File 'lib/fairy/controller.rb', line 981

def initialize(mapper)
	super
	@export = nil
	@import = nil
end

Instance Method Details

#assign_ntask(&block) ⇒ Object

# File 'lib/fairy/controller.rb', line 987

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

#bind_input(njob) ⇒ Object

# File 'lib/fairy/controller.rb', line 1006

def bind_input(njob)
	@import.no = @export.no
	@import.key = @export.key
	njob.input = @import
	@export.output = @import
	pre_bjob.bind_export(@export, @import)
end