threadpool

thread_pool.rb

require 'thread'

class ThreadPool
  attr_reader :queue, :threads

  def initialize(size = 10)
    @queue = Queue.new
    @threads = []

    size.times do
      @threads << Thread.new do
        catch(:done) do
          loop do
            job, args = @queue.pop
            job.call(*args)
          end
        end
      end
    end
  end

  def add(*args, &block)
    @queue << [block, args]
  end

  def run
    @threads.size.times do
      add do
        throw :done
      end
    end

    @threads.each(&:join)
  end
end

This is sick! I can't believe you took 35 lines.