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
InterruptedException
public E take() throws InterruptedException
InterruptedException
public Object[] takeSnapshot()