# File lib/em/threaded_resource.rb, line 83 def shutdown @running = false @queue << lambda {} @thread.join end