thread_pool

Ahmed Khaled · @nemoload · over 2 years

def thread_pool(pool_size: 4, jobs:, &block)
  threads = []
  results = []
  mutex = Mutex.new

  pool_size.times do
    threads << Thread.new do
      while !jobs.empty? do
        job = jobs.pop(true)
        result = block.call(job)
        mutex.synchronize { results << result }
      end
    end
  end
  threads.map(&:join)
  results

end