Class: CobraCommander::Executor::Concurrent

Inherits:

Object

• Object
• CobraCommander::Executor::Concurrent

Defined in:

lib/cobra_commander/executor/concurrent.rb

Overview

Execute a command on multiple components concurrently

Instance Method Summary

• #exec(command) ⇒ Object
• #initialize(components, concurrency:, spin_output:) ⇒ Concurrent constructor

  A new instance of Concurrent.

Constructor Details

#initialize(components, concurrency:, spin_output:) ⇒ Concurrent

Returns a new instance of Concurrent.

# File 'lib/cobra_commander/executor/concurrent.rb', line 10

def initialize(components, concurrency:, spin_output:)
  @components = components
  @multi = TTY::Spinner::Multi.new(":spinner :task", output: spin_output)
  @semaphore = ::Concurrent::Semaphore.new(concurrency)
end

Instance Method Details

#exec(command) ⇒ Object

# File 'lib/cobra_commander/executor/concurrent.rb', line 16

def exec(command)
  @multi.top_spinner.update(task: "Running #{command}")
  @results = []
  @components.each do |component|
    register_job(component, command)
  end
  @multi.auto_spin
  @results
end