Liferay 6.1.2-ce-ga3

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

java.lang.Object
  extended by com.liferay.portal.kernel.concurrent.TaskQueue<E>

public class TaskQueue<E>
extends Object


Constructor Summary
TaskQueue()
           
TaskQueue(int capacity)
           
 
Method Summary
 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 java.lang.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()

Liferay 6.1.2-ce-ga3