A thread pool for mikhael_k33hl's #ruby irc use case

thread_pool.rb

Thread.abort_on_exception = true

class ThreadPool
  attr_reader :threads
  attr_reader :queue

  def initialize size: 10
    @queue = Queue.new
    @threads = Array.new size do
      Thread.new do
        loop do
          @queue.pop.call
          break if @queue.empty?
        end
      end
    end
  end

  def << work
    @queue << work
  end
end

pool = ThreadPool.new

20.times do |n|
  work = ->{ sleep 10; puts n }
  pool << work
end

pool.threads.each &:join