Class ConcurrentLinkedBlockingQueue<T>

java.lang.Object

java.util.AbstractCollection<T>

java.util.AbstractQueue<T>

java.util.concurrent.ConcurrentLinkedQueue<T>

org.jgroups.util.ConcurrentLinkedBlockingQueue<T>

Type Parameters:

T - T

All Implemented Interfaces:

Serializable, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>

public class ConcurrentLinkedBlockingQueue<T>
extends ConcurrentLinkedQueue<T>
implements BlockingQueue<T>

Concurrent queue which offers optional blocking on empty / full. Designed for multiple producers, but only a single consumer. Only methods required by message bundlers (offer(), poll(), drainTo(), size() etc) are implemented. Might add more implementation as needed.
See https://issues.redhat.com/browse/JGRP-2890 for details

Since:

5.5.0

Author:

Bela Ban

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	block_on_empty
protected final boolean	block_on_full
protected final int	capacity
protected final IntUnaryOperator	INCR
protected final Lock	lock
protected final Condition	not_empty
protected final Condition	not_full
protected final AtomicInteger	size

Constructor Summary

Constructors

Constructor	Description
ConcurrentLinkedBlockingQueue(int capacity, boolean block_on_empty, boolean block_on_full)

Method Summary

Modifier and Type	Method	Description
boolean	add(T t)
boolean	addAll(Collection<? extends T> c)
void	clear()
int	drainTo(Collection<? super T> c)
int	drainTo(Collection<? super T> c, int max)
boolean	isEmpty()
boolean	offer(T t)
boolean	offer(T t, long timeout, TimeUnit unit)
T	poll()
T	poll(long timeout, TimeUnit unit)
void	put(T t)
int	remainingCapacity()
T	remove()
boolean	remove(Object o)
boolean	removeAll(Collection<?> c)
boolean	removeIf(Predicate<? super T> filter)
boolean	retainAll(Collection<?> c)
protected void	signalNotEmpty()
protected void	signalNotFull()
int	size()
T	take()

Methods inherited from class ConcurrentLinkedQueue

contains, forEach, iterator, peek, spliterator, toArray, toArray, toString

Methods inherited from class AbstractQueue

element

Methods inherited from class AbstractCollection

containsAll

Methods inherited from class Object

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

Methods inherited from interface BlockingQueue

contains

Methods inherited from interface Collection

containsAll, equals, hashCode, iterator, parallelStream, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface Iterable

forEach

Methods inherited from interface Queue

element, peek

Field Details

capacity

protected final int capacity

size

protected final AtomicInteger size

block_on_empty

protected final boolean block_on_empty

block_on_full

protected final boolean block_on_full

lock

protected final Lock lock

not_empty

protected final Condition not_empty

not_full

protected final Condition not_full

INCR

protected final IntUnaryOperator INCR

Constructor Details

ConcurrentLinkedBlockingQueue

public ConcurrentLinkedBlockingQueue(int capacity,
 boolean block_on_empty,
 boolean block_on_full)

Method Details

put

public void put(T t)
         throws InterruptedException

Specified by:

put in interface BlockingQueue<T>

Throws:

InterruptedException

add

public boolean add(T t)

Specified by:

add in interface BlockingQueue<T>

Specified by:

add in interface Collection<T>

Specified by:

add in interface Queue<T>

Overrides:

add in class ConcurrentLinkedQueue<T>

addAll

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

Specified by:

addAll in interface Collection<T>

Overrides:

addAll in class ConcurrentLinkedQueue<T>

offer

public boolean offer(T t)

Specified by:

offer in interface BlockingQueue<T>

Specified by:

offer in interface Queue<T>

Overrides:

offer in class ConcurrentLinkedQueue<T>

offer

public boolean offer(T t,
 long timeout,
 TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface BlockingQueue<T>

Throws:

InterruptedException

clear

public void clear()

Specified by:

clear in interface Collection<T>

Overrides:

clear in class ConcurrentLinkedQueue<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<T>

Overrides:

isEmpty in class ConcurrentLinkedQueue<T>

poll

public T poll()

Specified by:

poll in interface Queue<T>

Overrides:

poll in class ConcurrentLinkedQueue<T>

poll

public T poll(long timeout,
 TimeUnit unit)
       throws InterruptedException

Specified by:

poll in interface BlockingQueue<T>

Throws:

InterruptedException

take

public T take()
       throws InterruptedException

Specified by:

take in interface BlockingQueue<T>

Throws:

InterruptedException

drainTo

public int drainTo(Collection<? super T> c)

Specified by:

drainTo in interface BlockingQueue<T>

drainTo

public int drainTo(Collection<? super T> c,
 int max)

Specified by:

drainTo in interface BlockingQueue<T>

remove

public T remove()

Specified by:

remove in interface Queue<T>

Overrides:

remove in class AbstractQueue<T>

remove

public boolean remove(Object o)

Specified by:

remove in interface BlockingQueue<T>

Specified by:

remove in interface Collection<T>

Overrides:

remove in class ConcurrentLinkedQueue<T>

removeAll

public boolean removeAll(Collection<?> c)

Specified by:

removeAll in interface Collection<T>

Overrides:

removeAll in class ConcurrentLinkedQueue<T>

removeIf

public boolean removeIf(Predicate<? super T> filter)

Specified by:

removeIf in interface Collection<T>

Overrides:

removeIf in class ConcurrentLinkedQueue<T>

retainAll

public boolean retainAll(Collection<?> c)

Specified by:

retainAll in interface Collection<T>

Overrides:

retainAll in class ConcurrentLinkedQueue<T>

size

public int size()

Specified by:

size in interface Collection<T>

Overrides:

size in class ConcurrentLinkedQueue<T>

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface BlockingQueue<T>

signalNotEmpty

protected void signalNotEmpty()

signalNotFull

protected void signalNotFull()