com.liferay.portal.kernel.concurrent

Class TaskQueue<E>

Object

com.liferay.portal.kernel.concurrent.TaskQueue<E>

public class TaskQueue<E>
extends Object

Author:

Shuyang Zhou

Constructor Summary

Constructors

Constructor and Description
TaskQueue()
TaskQueue(int capacity)

Method Summary

Modifier and Type	Method and Description
int	drainTo(Collection<E> collection)
protected ReentrantLock	getPutLock()
protected ReentrantLock	getTakeLock()
boolean	isEmpty()
boolean	offer(E element, boolean[] hasWaiterMarker)
E	poll()
E	poll(long timeout, TimeUnit timeUnit)
int	remainingCapacity()
boolean	remove(E element)
int	size()
E	take()

Methods inherited from class Object

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

Constructor Detail

TaskQueue

public TaskQueue()

TaskQueue

public TaskQueue(int capacity)

Method Detail

drainTo

public int drainTo(Collection<E> collection)

isEmpty

public boolean isEmpty()

offer

public boolean offer(E element,
                     boolean[] hasWaiterMarker)

poll

public E poll()

poll

public E poll(long timeout,
              TimeUnit timeUnit)
       throws InterruptedException

Throws:

InterruptedException

remainingCapacity

public int remainingCapacity()

remove

public boolean remove(E element)

size

public int size()

take

public E take()
       throws InterruptedException

Throws:

InterruptedException

getPutLock

protected ReentrantLock getPutLock()

getTakeLock

protected ReentrantLock getTakeLock()