public class FifoMap extends ConcurrentHashMap<String,BlockingQueue<Object>>
ConcurrentHashMap.KeySetView<K,V>AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>| Modifier and Type | Field and Description |
|---|---|
static String |
CAPACITY_PROP |
static String |
TIMEOUT_PROP |
| Modifier and Type | Method and Description |
|---|---|
Object |
get(String fifoName) |
static FifoMap |
getInstance() |
int |
length(String fifoName) |
Object |
pop(String fifoName) |
Object |
pop(String fifoName,
long timeout) |
void |
put(String fifoName,
Object v) |
clear, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, forEach, forEach, forEachEntry, forEachEntry, forEachKey, forEachKey, forEachValue, forEachValue, get, getOrDefault, hashCode, isEmpty, keys, keySet, keySet, mappingCount, merge, newKeySet, newKeySet, put, putAll, putIfAbsent, reduce, reduceEntries, reduceEntries, reduceEntriesToDouble, reduceEntriesToInt, reduceEntriesToLong, reduceKeys, reduceKeys, reduceKeysToDouble, reduceKeysToInt, reduceKeysToLong, reduceToDouble, reduceToInt, reduceToLong, reduceValues, reduceValues, reduceValuesToDouble, reduceValuesToInt, reduceValuesToLong, remove, remove, replace, replace, replaceAll, search, searchEntries, searchKeys, searchValues, size, toString, valuesclonepublic static final String TIMEOUT_PROP
public static final String CAPACITY_PROP
public static FifoMap getInstance()
public Object pop(String fifoName, long timeout) throws InterruptedException
InterruptedExceptionpublic Object pop(String fifoName) throws InterruptedException
InterruptedExceptionpublic int length(String fifoName)
public void put(String fifoName, Object v) throws InterruptedException
InterruptedExceptionCopyright © 2016. All rights reserved.