class Concurrent::FixedThreadPool

def shutdown
  @mutex.synchronize do
    break unless @state == :running
    if @pool.empty?
      @state = :shutdown
      @terminator.set
    else
      @state = :shuttingdown
      @pool.length.times{ @queue << :stop }
    end
  end
end