Liferay 6.0.5

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 Object


Constructor Summary
CoalescedPipe()
           
CoalescedPipe(Comparator<E> comparator)
           
 
Method Summary
 long coalescedCount()
           
 int pendingCount()
           
 void put(E e)
           
 E take()
           
 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(Comparator<E> comparator)
Method Detail

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

Liferay 6.0.5