Class: QuietQuality::Executors::ConcurrentExecutor

Inherits:
BaseExecutor
  • Object
show all
Defined in:
lib/quiet_quality/executors/concurrent_executor.rb

Instance Method Summary collapse

Methods inherited from BaseExecutor

#any_failure?, #failed_outcomes, #initialize, #messages, #outcomes, #successful_outcomes

Constructor Details

This class inherits a constructor from QuietQuality::Executors::BaseExecutor

Instance Method Details

#execute! ⇒ Object 



4
5
6
7
8
 
# File 'lib/quiet_quality/executors/concurrent_executor.rb', line 4

def execute!
  threads = pipelines.map { |pipeline| threaded_pipeline(pipeline) }
  threads.each(&:join)
  pipelines.none?(&:failure?)
end