很多线程可能会填充一个HashMap，在某些情况下我需要等待（阻塞）直到HashMap中存在一个对象，例如：
BlockingConcurrentHashMap map = new BlockingConcurrentHashMap();
Object x = map.getAndWait(key, 1000); //(object_to_get, max_delay_ms)
想知道这样的事情是否已经存在，我讨厌重新发明轮子。
【问题讨论】：
标签： java concurrency java.util.concurrent
据我所知，没有可用的“转移地图”。虽然理论上创造一个并不太难。
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;
}
}
在这个类中有明显的排除。更不用说锁粗化了；不用说它的表现不会很好，但你应该知道发生了什么
【讨论】：
Blockingmap4j 将正好满足您的要求。
你可以在https://github.com/sarveswaran-m/blockingMap4j/wiki/找到它
由于在实现中使用了粒度锁，因此性能不会严重下降。
PS
对于一个 2 岁的问题，这是一个相当晚的答案。由于无法向问题的作者发送私信，我在这里回复。
免责声明
我是图书馆的作者。
【讨论】：
改进 John 的 impl，使用目标 notify()，而不是“雷鸣般的羊群”，这在没有人等待插入的密钥时尤其糟糕
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
【讨论】：
您可以在开始时使用java.util.concurrent.FutureTask<ObjReturned>s 填充您的Hashtable，其中包含您需要计算的所有任务。然后您使用线程池开始执行您的FutureTasks。您可以使用ObjReturned obj = hashtable.get(key).get() 异步获取结果，如果相关FutureTask 尚未完成，它将等待。
您可能不希望单个线程检索结果，因为它可能会等待最终完成的任务。你可以有多个检索线程，或者当你等待一个任务太久时你可以循环遍历键（有一个方法FutureTask.get(waitTime, timeUnit)）。
【讨论】：
我不确定你的问题是什么。当它不在地图中时，您要等待该值吗？您想要地图上的 BlockingQueue 的生产者-消费者模式。如果是我在 JRE 或其他任何地方都不知道类似的东西。
Google guava MapMaker 允许您制作计算地图，即使用 Function
【讨论】：
Function 可以简单地封装阻塞，直到密钥出现在地图中。这是将“阻塞”方面与“地图”方面分开的一种相对不错的方式，并且还可以非常简单地允许多种策略（例如，旋转 vs. 睡眠 vs. wait-notifyAll vs. ...）