@Deprecated
public class BatchablePipe<K,V>
extends Object
| Modifier and Type | Class and Description |
|---|---|
protected static class |
BatchablePipe.IncreasableEntryWrapper<K,V>
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentMap<K,BatchablePipe.IncreasableEntryWrapper<K,V>> |
concurrentMap
Deprecated.
|
protected Queue<IncreasableEntry<K,V>> |
queue
Deprecated.
|
| Constructor and Description |
|---|
BatchablePipe()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
put(IncreasableEntry<K,V> increasableEntry)
Deprecated.
|
IncreasableEntry<K,V> |
take()
Deprecated.
|
protected final ConcurrentMap<K,BatchablePipe.IncreasableEntryWrapper<K,V>> concurrentMap
protected final Queue<IncreasableEntry<K,V>> queue
public boolean put(IncreasableEntry<K,V> increasableEntry)
public IncreasableEntry<K,V> take()