Module: Mutant::Parallel Private

Defined in:
lib/mutant/parallel.rb,
lib/mutant/parallel/pipe.rb,
lib/mutant/parallel/driver.rb,
lib/mutant/parallel/source.rb,
lib/mutant/parallel/worker.rb,
lib/mutant/parallel/connection.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

Defined Under Namespace

Modules: Sink Classes: Config, Connection, Driver, Pipe, Response, Source, Status, Worker

Class Method Summary collapse

Class Method Details

.async(config:, world:) ⇒ 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:



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

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

  world.process_warmup

  workers = workers(world, config, shared)

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