Class: Ruptr::Runner::Parallel

Inherits:

Ruptr::Runner

• Object
• Ruptr::Runner
• Ruptr::Runner::Parallel

Defined in:

lib/ruptr/runner.rb

Direct Known Subclasses

Forking, Threaded

Instance Attribute Summary

• #parallel_jobs ⇒ Object readonly

  Returns the value of attribute parallel_jobs.

Attributes inherited from Ruptr::Runner

#capture_output, #golden_store, #timing_store

Class Method Summary

• .default_parallel_jobs ⇒ Object

Instance Method Summary

• #initialize(parallel_jobs: self.class.default_parallel_jobs, **opts) ⇒ Parallel constructor

  A new instance of Parallel.

Methods inherited from Ruptr::Runner

class_from_env, #dispatch, #expected_processor_time, find_runner, from_env, opts_from_env, #run_report, #run_sink

Constructor Details

#initialize(parallel_jobs: self.class.default_parallel_jobs, **opts) ⇒ Parallel

Returns a new instance of Parallel.

# File 'lib/ruptr/runner.rb', line 259

def initialize(parallel_jobs: self.class.default_parallel_jobs, **opts)
  super(**opts)
  @parallel_jobs = parallel_jobs
end

Instance Attribute Details

#parallel_jobs ⇒ Object (readonly)

Returns the value of attribute parallel_jobs.

# File 'lib/ruptr/runner.rb', line 264

def parallel_jobs
  @parallel_jobs
end

Class Method Details

.default_parallel_jobs ⇒ Object

# File 'lib/ruptr/runner.rb', line 254

def self.default_parallel_jobs
  require 'etc'
  Etc.nprocessors
end