12

许多线程可能会填充一个HashMap，在某些情况下我需要等待（阻塞）直到 HashMap 中存在一个对象，例如：

BlockingConcurrentHashMap map = new BlockingConcurrentHashMap();
Object x = map.getAndWait(key, 1000);    //(object_to_get, max_delay_ms)

想知道这样的事情是否已经存在，我讨厌重新发明轮子。

4

5 回答 5

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;
   }
  }

在这个类中有明显的排除。更不用说锁粗化了；不用说它的表现不会很好，但你应该知道发生了什么

于 2011-06-17T17:16:46.777 回答
4

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

PS
这是一个2岁的问题的相当晚的答案。由于无法向问题的作者发送私人消息，因此我在这里回复。

免责声明
我是图书馆的作者。

于 2013-05-03T07:57:06.703 回答
3

改进了 John 的 impl，使用了针对性的 notify()，而不是“thundering herd”，当没有人等待插入的密钥时，这尤其糟糕

HashMap<K,Object> locks = new HashMap<>();

put(key, value)
    synchronized(locks)
        backingMap.put(key,value);

        lock = locks.get(key);
        if(lock!=null)
            lock.notifyAll();

getAndWait(key)
    // not hard, but pretty verbose
于 2011-06-17T17:30:33.397 回答
3

您可以在开始时用您需要计算的所有任务填充您的Hashtablewith 。java.util.concurrent.FutureTask<ObjReturned>然后，您使用线程池开始执行您FutureTask的 s. 您可以使用 异步获取结果，如果相关问题尚未完成ObjReturned obj = hashtable.get(key).get()，它将等待。FutureTask

您可能不希望单个线程检索结果，因为它可能会等待最终完成的任务。您可以有多个检索线程，或者当您等待一个任务太久时（有一个方法FutureTask.get(waitTime, timeUnit)），您可以循环通过键。

于 2011-06-17T18:28:04.860 回答
0

我不确定你的问题是什么。当它不在地图中时，您要等待该值吗？您想要地图上的 BlockingQueue 的生产者-消费者模式。如果是我在 JRE 或其他任何地方都不知道类似的东西。

Google guava MapMaker 允许您制作计算地图，即使用 Function<Key, Value> 类型的工厂在不存在时创建值的 Map。如果多个线程同时达到这种情况，一个线程会创建该值，而其余线程会等待它。我知道这不是生产者-消费者，而是我能提供的。

于 2011-06-17T17:10:27.353 回答