class Async::Container::Hybrid
Provides a hybrid multi-process multi-thread container.
Public Instance Methods
run(count: nil, forks: nil, threads: nil, **options, &block)
click to toggle source
Run multiple instances of the same block in the container. @parameter count [Integer] The number of instances to start. @parameter forks [Integer] The number of processes to fork. @parameter threads [Integer] the number of threads to start.
# File lib/async/container/hybrid.rb, line 34 def run(count: nil, forks: nil, threads: 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, **options, &block) container.wait_until_ready instance.ready! container.wait rescue Async::Container::Terminate # Stop it immediately: container.stop(false) ensure # Stop it gracefully (also code path for Interrupt): container.stop end end return self end