Class: Archivededup::QueueAppender

Inherits:

Object

Object
Archivededup::QueueAppender

show all

Defined in:: lib/archivededup/paralleltask.rb

Instance Method Summary collapse

#enq(d) ⇒ Object (also: #<<)
#initialize(queue) ⇒ QueueAppender constructor

A new instance of QueueAppender.

Constructor Details

#initialize(queue) ⇒ `QueueAppender`

Returns a new instance of QueueAppender.



6
7
8

# File 'lib/archivededup/paralleltask.rb', line 6

def initialize(queue)
  @queue = queue
end

Instance Method Details

#enq(d) ⇒ `Object` Also known as: <<

# File 'lib/archivededup/paralleltask.rb', line 10

def enq d
  # Fill the queue and feed the threads.
  while @queue.length > 100
    sleep 1
  end
  @queue.enq d
end