@Test public void testPut() throws Exception { System.out.println("put"); String k = "test"; FifoMap instance = FifoMap.getInstance(); instance.put(k, "val1"); instance.put(k, "val2"); instance.put("", "test"); }
public void put(String fifoName, Object v) throws InterruptedException { getFifo(fifoName).offer(v, Long.MAX_VALUE, TimeUnit.SECONDS); }
FifoMap extends ConcurrentHashMap<String, BlockingQueue<Object>> { public void put(String fifoName, Object v) throws InterruptedException { getFifo(fifoName).offer(v, Long.MAX_VALUE, TimeUnit.SECONDS); } }
FifoMap extends ConcurrentHashMap<String, BlockingQueue<Object>> { public void put(String fifoName, Object v) throws InterruptedException { getFifo(fifoName).offer(v, Long.MAX_VALUE, TimeUnit.SECONDS); } private  FifoMap(); }
FifoMap extends ConcurrentHashMap<String, BlockingQueue<Object>> { public void put(String fifoName, Object v) throws InterruptedException { getFifo(fifoName).offer(v, Long.MAX_VALUE, TimeUnit.SECONDS); } private  FifoMap(); static FifoMap getInstance(); Object get(String fifoName); Object pop(String fifoName, long timeout); Object pop(String fifoName); int length(String fifoName); void put(String fifoName, Object v); }
FifoMap extends ConcurrentHashMap<String, BlockingQueue<Object>> { public void put(String fifoName, Object v) throws InterruptedException { getFifo(fifoName).offer(v, Long.MAX_VALUE, TimeUnit.SECONDS); } private  FifoMap(); static FifoMap getInstance(); Object get(String fifoName); Object pop(String fifoName, long timeout); Object pop(String fifoName); int length(String fifoName); void put(String fifoName, Object v); static final String TIMEOUT_PROP; static final String CAPACITY_PROP; }