com.liferay.portal.kernel.concurrent

Class CoalescedPipe<E>

Object

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

public class CoalescedPipe<E>
extends Object

Author:

Shuyang Zhou

Constructor Summary

Constructors

Constructor and Description
CoalescedPipe()
CoalescedPipe(Comparator<E> comparator)

Method Summary

Modifier and Type	Method and Description
long	coalescedCount()
int	pendingCount()
void	put(E e)
E	take()
Object[]	takeSnapshot()

Methods inherited from class 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()