Liferay 7.0-ce-b4

com.liferay.portal.kernel.concurrent
Class BatchablePipe<K,V>

java.lang.Object
  extended by com.liferay.portal.kernel.concurrent.BatchablePipe<K,V>

public class BatchablePipe<K,V>
extends Object


Nested Class Summary
protected static class BatchablePipe.IncreasableEntryWrapper<K,V>
           
 
Field Summary
protected  ConcurrentMap<K,BatchablePipe.IncreasableEntryWrapper<K,V>> concurrentMap
           
protected  Queue<IncreasableEntry<K,V>> queue
           
 
Constructor Summary
BatchablePipe()
           
 
Method Summary
 boolean put(IncreasableEntry<K,V> increasableEntry)
           
 IncreasableEntry<K,V> take()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

concurrentMap

protected final ConcurrentMap<K,BatchablePipe.IncreasableEntryWrapper<K,V>> concurrentMap

queue

protected final Queue<IncreasableEntry<K,V>> queue
Constructor Detail

BatchablePipe

public BatchablePipe()
Method Detail

put

public boolean put(IncreasableEntry<K,V> increasableEntry)

take

public IncreasableEntry<K,V> take()

Liferay 7.0-ce-b4