Class: ForgetfulQueue

Inherits:

Queue

• Object
• Queue
• ForgetfulQueue

Defined in:

lib/autumn/misc.rb

Overview

An implementation of SizedQueue that, instead of blocking when the queue is full, simply discards the overflow, forgetting it.

Instance Method Summary

• #full? ⇒ Boolean

  Returns true if this queue is at maximum size.

• #initialize(capacity) ⇒ ForgetfulQueue constructor

  Creates a new sized queue.

• #push(obj) ⇒ Object (also: #<<, #enq)

  Pushes an object onto the queue.

Constructor Details

#initialize(capacity) ⇒ ForgetfulQueue

Creates a new sized queue.

# File 'lib/autumn/misc.rb', line 56

def initialize(capacity)
  @max = capacity
end

Instance Method Details

#full? ⇒ Boolean

Returns true if this queue is at maximum size.

Returns:

• (Boolean)

# File 'lib/autumn/misc.rb', line 62

def full?
  size == @max
end

#push(obj) ⇒ Object Also known as: <<, enq

Pushes an object onto the queue. If there is no space left on the queue, does nothing.

# File 'lib/autumn/misc.rb', line 69

def push(obj)
  Thread.exclusive { super unless full? }
end