Module: Mutant::Parallel Private

Defined in:
lib/mutant/parallel.rb,
lib/mutant/parallel/driver.rb,
lib/mutant/parallel/source.rb,
lib/mutant/parallel/worker.rb

Overview

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Parallel execution engine of arbitrary payloads

API:

  • private

Defined Under Namespace

Classes: Config, Driver, Sink, Source, Status, Worker

Class Method Summary collapse

Class Method Details

.async(world, config) ⇒ Driver

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Run async computation returning driver

Parameters:

Returns:

API:

  • private



13
14
15
16
17
18
19
20
21
22
 
# File 'lib/mutant/parallel.rb', line 13

def self.async(world, config)
  shared  = shared_state(world, config)
  workers = workers(world, config, shared)

  Driver.new(
    workers: workers,
    threads: threads(world, config, workers),
    **shared
  )
end