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