public class CoalescedPipe<E> extends Object
| Constructor and Description |
|---|
CoalescedPipe() |
CoalescedPipe(Comparator<E> comparator) |
public CoalescedPipe()
public CoalescedPipe(Comparator<E> comparator)
public long coalescedCount()
public int pendingCount()
public void put(E e) throws InterruptedException
InterruptedExceptionpublic E take() throws InterruptedException
InterruptedExceptionpublic Object[] takeSnapshot()