ruby - 为什么在 Celluloid::IO 中调用 sleep 时进程永远阻塞

Question

我正在使用 Celluloid::IO 进行 DNS 查询，下面是我的代码:

require 'celluloid/io'

class MyResolver
    include Celluloid::IO

    def initialize
        @resolver = DNSResolver.new
    end 

    def resolve(domain)
        ips = @resolver.resolve domain

        #sleep 1
        return {domain: domain, ip: ips}
    end 
end

pool = MyResolver.pool(size: 5)

domains = [ 
    'www.google.com',
    ## many other record
]

futures = domains.map {|d| pool.future.resolve(d)}

futures.each do |future|
    puts "#{future.value}"
end

此代码可在几秒钟内运行并完成。但是当我添加行 sleep 1(仅用于学习目的)时，打印一些结果后，进程永远阻塞，这很奇怪。

感谢您的帮助。

Answer 1

sleep 是 Celluloid 中的重写关键字，因此如果您想要 Ruby 本身的 sleep，请使用 内核 sleep 。但话虽如此，从 Celluoid::IO 的 0.17.0-dependent 分支开始，您描述的这个错误不存在(不再？)。

我使用你的可重现失败案例来测试新的 celluloid-pool gem 在 Celluloid 的 0.17.0 版本中发布，并且它 sleep 1 按原样工作没有问题。