Class: Async::Container::Hybrid

Inherits:
Forked show all
Defined in:
lib/async/container/hybrid.rb

Overview

Provides a hybrid multi-process multi-thread container.

Constant Summary

Constants inherited from Generic

Generic::UNNAMED

Instance Attribute Summary

Attributes inherited from Generic

#The group of running children instances., #group, #state, #statistics

Instance Method Summary collapse

Methods inherited from Forked

multiprocess?, #start

Methods inherited from Generic

#The state of each child instance.=, #[], #async, #failed?, #initialize, #key?, #mark?, #reload, run, #running?, #size, #sleep, #spawn, #status?, #stop, #to_s, #wait, #wait_until_ready

Constructor Details

This class inherits a constructor from Async::Container::Generic

Instance Method Details

#run(count: nil, forks: nil, threads: nil, health_check_timeout: nil, **options, &block) ⇒ Object

Run multiple instances of the same block in the container.



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/async/container/hybrid.rb', line 19

def run(count: nil, forks: nil, threads: nil, health_check_timeout: nil, **options, &block)
  processor_count = Container.processor_count
  count ||= processor_count ** 2
  forks ||= [processor_count, count].min
  threads ||= (count / forks).ceil
  
  forks.times do
    self.spawn(**options) do |instance|
      container = Threaded.new
      
      container.run(count: threads, health_check_timeout: health_check_timeout, **options, &block)
      
      container.wait_until_ready
      instance.ready!
      
      container.wait
    rescue Async::Container::Terminate
      # Stop it immediately:
      container.stop(false)
      raise
    ensure
      # Stop it gracefully (also code path for Interrupt):
      container.stop
    end
  end
  
  return self
end