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

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

public class CoalescedPipe<E>
extends java.lang.Object

View Source

Author:
Shuyang Zhou

Constructor Summary
CoalescedPipe()
           
CoalescedPipe(java.util.Comparator<E> comparator)
           
 
Method Summary
 long coalescedCount()
           
 int pendingCount()
           
 void put(E e)
           
 E take()
           
 java.lang.Object[] takeSnapshot()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CoalescedPipe

public CoalescedPipe()

CoalescedPipe

public CoalescedPipe(java.util.Comparator<E> comparator)
Method Detail

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()