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