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

API:

  • private

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:

API:

  • private



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