org.eclipse.emf.ecp.view.internal.validation

Class ConcurrentLinkedSetQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<E>

org.eclipse.emf.ecp.view.internal.validation.ConcurrentLinkedSetQueue<E>

Type Parameters:

E - the generic type of the elements to be queued.

All Implemented Interfaces:

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

public class ConcurrentLinkedSetQueue<E>
extends ConcurrentLinkedQueue<E>

An extension of ConcurrentLinkedQueue that additionally contains a set to avoid unnecessary duplicated entries in cases of non-concurrent additions. Duplication may still occur if multiple threads enqueue the same objects.

Author:

nicole.behlen

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConcurrentLinkedSetQueue()

Method Summary

Modifier and Type	Method and Description
boolean	addAll(Collection<? extends E> c)
Iterator<E>	iterator()
boolean	offer(E e) Adds the object to the tail of this queue, if not already contained.
E	poll()
boolean	remove(Object o)

Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue

add, contains, isEmpty, peek, 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

ConcurrentLinkedSetQueue

public ConcurrentLinkedSetQueue()

Method Detail

offer

public boolean offer(E e)

Adds the object to the tail of this queue, if not already contained.

Specified by:

offer in interface Queue<E>

Overrides:

offer in class ConcurrentLinkedQueue<E>

Parameters:

e - adds if not already contained the object to the tail of this queue

Returns:

false if object is already contained in queue, true otherwise.

Throws:

NullPointerException - - if the specified element is null

poll

public E poll()

Specified by:

poll in interface Queue<E>

Overrides:

poll in class ConcurrentLinkedQueue<E>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<E>

Overrides:

remove in class ConcurrentLinkedQueue<E>

addAll

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

Specified by:

addAll in interface Collection<E>

Overrides:

addAll in class ConcurrentLinkedQueue<E>

iterator

public Iterator<E> iterator()

Specified by:

iterator in interface Iterable<E>

Specified by:

iterator in interface Collection<E>

Overrides:

iterator in class ConcurrentLinkedQueue<E>