org.nuxeo.ecm.core.work

Class NuxeoBlockingQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<Runnable>

org.nuxeo.ecm.core.work.NuxeoBlockingQueue

All Implemented Interfaces:

Iterable<Runnable>, Collection<Runnable>, BlockingQueue<Runnable>, Queue<Runnable>

Direct Known Subclasses:

MemoryBlockingQueue, RedisBlockingQueue

public abstract class NuxeoBlockingQueue
extends AbstractQueue<Runnable>
implements BlockingQueue<Runnable>

An abstract BlockingQueue suitable for a fixed-sized ThreadPoolExecutor, that can be implemented in terms of a few methods. offer(java.lang.Runnable) always succeeds.

Since:

5.8

Constructor Summary

Constructors

Constructor and Description
NuxeoBlockingQueue()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	contains(Object o)
int	drainTo(Collection<? super Runnable> c)
int	drainTo(Collection<? super Runnable> c, int maxElements)
abstract int	getQueueSize() Gets the size of the queue.
Iterator<Runnable>	iterator()
boolean	offer(Runnable r)
boolean	offer(Runnable r, long timeout, TimeUnit unit)
Runnable	peek()
Runnable	poll()
abstract Runnable	pollElement() Retrieves and removes an element from the queue, or returns null if the queue is empty.
void	put(Runnable r)
abstract void	putElement(Runnable r) Adds an element into this queue, waiting if necessary for space to become available.
int	remainingCapacity()
void	setActive(boolean active) Sets the queue active or inactive.
int	size()

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add, poll, remove, take

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray

Constructor Detail

NuxeoBlockingQueue

public NuxeoBlockingQueue()

Method Detail

setActive

public void setActive(boolean active)

Sets the queue active or inactive. When deactivated, taking an element from the queue (take, poll, peek) behaves as if the queue was empty. Elements can still be added when the queue is deactivated. When reactivated, all elements are again available.

Parameters:

active - true to make the queue active, or false to deactivate it

offer

public boolean offer(Runnable r)

Specified by:

offer in interface BlockingQueue<Runnable>

Specified by:

offer in interface Queue<Runnable>

offer

public boolean offer(Runnable r,
            long timeout,
            TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface BlockingQueue<Runnable>

Throws:

InterruptedException

put

public void put(Runnable r)
         throws InterruptedException

Specified by:

put in interface BlockingQueue<Runnable>

Throws:

InterruptedException

peek

public Runnable peek()

Specified by:

peek in interface Queue<Runnable>

poll

public Runnable poll()

Specified by:

poll in interface Queue<Runnable>

contains

public boolean contains(Object o)

Specified by:

contains in interface Collection<Runnable>

Specified by:

contains in interface BlockingQueue<Runnable>

Overrides:

contains in class AbstractCollection<Runnable>

size

public int size()

Specified by:

size in interface Collection<Runnable>

Specified by:

size in class AbstractCollection<Runnable>

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface BlockingQueue<Runnable>

iterator

public Iterator<Runnable> iterator()

Specified by:

iterator in interface Iterable<Runnable>

Specified by:

iterator in interface Collection<Runnable>

Specified by:

iterator in class AbstractCollection<Runnable>

drainTo

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

Specified by:

drainTo in interface BlockingQueue<Runnable>

drainTo

public int drainTo(Collection<? super Runnable> c,
          int maxElements)

Specified by:

drainTo in interface BlockingQueue<Runnable>

getQueueSize

public abstract int getQueueSize()

Gets the size of the queue.

putElement

public abstract void putElement(Runnable r)
                         throws InterruptedException

Adds an element into this queue, waiting if necessary for space to become available.

Throws:

InterruptedException

pollElement

public abstract Runnable pollElement()

Retrieves and removes an element from the queue, or returns null if the queue is empty.