Contents

# frozen_string_literal: true

module Relaton
  # Workers poll.
  class WorkersPool
    def initialize(workers = 2, &_block)
      num_workers = workers < 2 ? 2 : workers
      @queue = SizedQueue.new(num_workers * 2)
      @threads = Array.new num_workers do
        Thread.new do
          while item = @queue.pop
            yield(item)
          end
        end
      end
    end

    def <<(item)
      @queue << item
      self
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
relaton-1.7.7	lib/relaton/workers_pool.rb
relaton-1.7.pre7	lib/relaton/workers_pool.rb
relaton-1.7.6	lib/relaton/workers_pool.rb
relaton-1.7.5	lib/relaton/workers_pool.rb
relaton-1.7.4	lib/relaton/workers_pool.rb