Class: Lumin::ParallelExecutor

Inherits:
Object
  • Object
show all
Defined in:
lib/lumin/parallel_executor.rb

Defined Under Namespace

Classes: Assignment

Instance Method Summary collapse

Constructor Details

#initialize(config:, registry:, count:, worker_class: Worker) ⇒ ParallelExecutor

Returns a new instance of ParallelExecutor.



10
11
12
13
14
15
 
# File 'lib/lumin/parallel_executor.rb', line 10

def initialize(config:, registry:, count:, worker_class: Worker)
  @config = config
  @registry = registry
  @count = count
  @worker_class = worker_class
end

Instance Method Details

#call(files, **options) ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/lumin/parallel_executor.rb', line 17

def call(files, **options)
  if Process.respond_to?(:fork)
    process_parallel(files, options)
  else
    thread_parallel(files, options)
  end
end