public class CoalescedPipe<E> extends Object
| Constructor and Description |
|---|
CoalescedPipe() |
CoalescedPipe(Comparator<E> comparator) |
| Modifier and Type | Method and Description |
|---|---|
long |
coalescedCount() |
int |
pendingCount() |
void |
put(E e) |
E |
take() |
Object[] |
takeSnapshot() |
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()