com.liferay.portal.kernel.concurrent
Class BatchablePipe<K,V>
java.lang.Object
com.liferay.portal.kernel.concurrent.BatchablePipe<K,V>
public class BatchablePipe<K,V>
- extends Object
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
concurrentMap
protected final ConcurrentMap<K,BatchablePipe.IncreasableEntryWrapper<K,V>> concurrentMap
queue
protected final Queue<IncreasableEntry<K,V>> queue
BatchablePipe
public BatchablePipe()
put
public boolean put(IncreasableEntry<K,V> increasableEntry)
take
public IncreasableEntry<K,V> take()