io.neba.core.util

Class ConcurrentLinkedDistinctQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<E>

io.neba.core.util.ConcurrentLinkedDistinctQueue<E>

Type Parameters:

E - the collection type.

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, Queue<E>

public class ConcurrentLinkedDistinctQueue<E>
extends ConcurrentLinkedQueue<E>

This linked queue does not permit duplicates and removes already existing elements from the underlying collection prior to value insertion.

Author:

Olaf Otto

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConcurrentLinkedDistinctQueue()

Method Summary

Modifier and Type	Method and Description
boolean	add(E e) Removes the element prior to insertion.
boolean	addAll(Collection<? extends E> c) Removes all elements in the collection prior to insertion.

Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue

contains, isEmpty, iterator, offer, peek, poll, remove, size, spliterator, toArray, toArray

Methods inherited from class java.util.AbstractQueue

clear, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

clear, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

ConcurrentLinkedDistinctQueue

public ConcurrentLinkedDistinctQueue()

Method Detail

add

public boolean add(E e)

Removes the element prior to insertion.

Specified by:

add in interface Collection<E>

Specified by:

add in interface Queue<E>

Overrides:

add in class ConcurrentLinkedQueue<E>

Parameters:

e - must not be null.

addAll

public boolean addAll(Collection<? extends E> c)

Removes all elements in the collection prior to insertion.

Specified by:

addAll in interface Collection<E>

Overrides:

addAll in class ConcurrentLinkedQueue<E>

Parameters:

c - must not be null.