Class: Dissever::Processor

Inherits:
Object
  • Object
show all
Defined in:
lib/dissever/processor.rb

Overview

Processor object, for running multiprocessed tasks

Instance Method Summary collapse

Constructor Details

#initialize(params = {}, &block) ⇒ Processor

Returns a new instance of Processor.



7
8
9
10
11
 
# File 'lib/dissever/processor.rb', line 7

def initialize(params = {}, &block)
  @options = params
  @options[:size] ||= 10
  @targets = block.call
end

Instance Method Details

#run! ⇒ Object 



13
14
15
16
17
18
 
# File 'lib/dissever/processor.rb', line 13

def run!
  log '*' * @targets.size
  readers = fork_master
  log
  parse_readers(readers)
end