com.liferay.portal.kernel.concurrent
Class CoalescedPipe<E>
java.lang.Object
com.liferay.portal.kernel.concurrent.CoalescedPipe<E>
public class CoalescedPipe<E>
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CoalescedPipe
public CoalescedPipe()
CoalescedPipe
public CoalescedPipe(Comparator<E> comparator)
coalescedCount
public long coalescedCount()
pendingCount
public int pendingCount()
put
public void put(E e)
throws InterruptedException
- Throws:
InterruptedException
take
public E take()
throws InterruptedException
- Throws:
InterruptedException
takeSnapshot
public Object[] takeSnapshot()