# File lib/em/threaded_resource.rb, line 56 def initialize @resource = yield @running = true @queue = ::Queue.new @thread = Thread.new do @queue.pop.call while @running end end