squeue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<T>

bbflow.squeue<T>

Type Parameters:: T - Type of the elements in the queue

All Implemented Interfaces:: Serializable, Iterable<T>, Collection<T>, Queue<T>

public class squeue<T> extends ConcurrentLinkedQueue<T>

Reimplementation of ConcurrentLinkedQueue in Bounded manner Taken inspiration from Hadoop class BoundedConcurrentLinkedQueue

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type

Field

Description

private final long

maxSize

private final AtomicLong

size
Constructor Summary

Constructors

Constructor

Description

squeue()

squeue(long maxSize)
Method Summary

Modifier and Type

Method

Description

boolean

addAll(Collection<? extends T> c)

void

clear()

boolean

offer(T e)

T

poll()

static void

preload()

long

remainingCapacity()

boolean

remove(Object o)

int

size()

Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue
add, contains, forEach, isEmpty, iterator, peek, removeAll, removeIf, retainAll, spliterator, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue
element, remove

Methods inherited from class java.util.AbstractCollection
containsAll

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection
containsAll, equals, hashCode, parallelStream, stream, toArray

Methods inherited from interface java.util.Queue
element, remove

Field Details
- size
  
  private final AtomicLong size
- maxSize
  
  private final long maxSize
Constructor Details
- squeue
  
  public squeue()
- squeue
  
  public squeue(long maxSize)
Method Details
- preload
  
  public static void preload()
- addAll
  
  public boolean addAll(Collection<? extends T> c)
  
  Specified by:
  
  addAll in interface Collection<T>
  
  Overrides:
  
  addAll in class ConcurrentLinkedQueue<T>
- clear
  
  public void clear()
  
  Specified by:
  
  clear in interface Collection<T>
  
  Overrides:
  
  clear in class ConcurrentLinkedQueue<T>
- offer
  
  public boolean offer(T e)
  
  Specified by:
  
  offer in interface Queue<T>
  
  Overrides:
  
  offer in class ConcurrentLinkedQueue<T>
- poll
  
  public T poll()
  
  Specified by:
  
  poll in interface Queue<T>
  
  Overrides:
  
  poll in class ConcurrentLinkedQueue<T>
- remove
  
  public boolean remove(Object o)
  
  Specified by:
  
  remove in interface Collection<T>
  
  Overrides:
  
  remove in class ConcurrentLinkedQueue<T>
- size
  
  public int size()
  
  Specified by:
  
  size in interface Collection<T>
  
  Overrides:
  
  size in class ConcurrentLinkedQueue<T>
- remainingCapacity
  
  public long remainingCapacity()