# File lib/eventmachine.rb, line 1031 def self.spawn_threadpool until @threadpool.size == @threadpool_size.to_i thread = Thread.new do Thread.current.abort_on_exception = true while true op, cback = *@threadqueue.pop result = op.call @resultqueue << [result, cback] EventMachine.signal_loopbreak end end @threadpool << thread end @all_threads_spawned = true end