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, #policy, #state, #statistics

Instance Method Summary collapse

Methods inherited from Forked

multiprocess?, #start

Methods inherited from Generic

#The policy for managing child lifecycle events.=, #The state of each child instance.=, #[], #async, #failed?, #initialize, #interrupt, #key?, #mark?, #reload, run, #running?, #size, #sleep, #spawn, #status?, #stop, #stopping?, #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
47
 
# 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!
			
			begin
				container.wait
			rescue Interrupt
				# Gracefully interrupt child threads; parent process handles escalation.
				container.interrupt
				retry
			end
		ensure
			container.stop(false)
		end
	end
	
	return self
end