是否存在带有getAndWait()方法的HashMap?例如BlockingConcurrentHashMap实现?

Dav*_*rks 9 java concurrency java.util.concurrent

许多线程可能会填充a HashMap,在某些情况下我需要等待(阻塞)直到HashMap中存在对象,例如:

BlockingConcurrentHashMap map = new BlockingConcurrentHashMap();
Object x = map.getAndWait(key, 1000);    //(object_to_get, max_delay_ms)
Run Code Online (Sandbox Code Playgroud)

想知道这样的事情是否存在,我讨厌重新发明轮子.

Joh*_*int 5

据我所知,没有可用的“换乘地图”。虽然理论上创建一个并不太困难。

public class TransferMap<K,V> implements Map<K,V>{
  @GuardedBy("lock")
  private final HashMap<K,V> backingMap = new HashMap<K,V>();

  private final Object lock = new Object();
  public V getAndWait(Object key){
     synchronized(lock){
       V value = null;
         do{
            value = backingMap.get(key);

            if(value == null) lock.wait();

         }while(value == null); 
      }
      return value;
     }
   public V put(K key, V value){
      synchronized(lock){
         V value = backingMap.put(key,value);
         lock.notifyAll();
      }
     return value;
   }
  }
Run Code Online (Sandbox Code Playgroud)

此类中存在明显的例外情况。更不用说锁粗化了;不用说它不会表现得很好,但你应该了解发生了什么


Sar*_*ram 5

Blockingmap4j 正好适合您的要求。你可以在https://github.com/sarveswaran-m/blockingMap4j/wiki/
找到它, 由于实现中使用了粒度锁,因此性能不会严重下降。

PS
这是对一个 2 年前的问题的一个相当晚的答案。由于无法向问题作者发送私信,所以在此回复。

免责声明
我是该库的作者。

  • 您应该添加一个免责声明,表明您是该库的作者。 (2认同)