diff --git a/lib/async/container/hybrid.rb b/lib/async/container/hybrid.rb index 28fb47e..4a27836 100644 --- a/lib/async/container/hybrid.rb +++ b/lib/async/container/hybrid.rb @@ -35,7 +35,7 @@ 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 + threads ||= (count / forks).ceil forks.times do self.spawn(**options) do |instance|