线程安全的队列图

作者: 银环蛇
发布时间: 2024-12-16 07:55:57 (21天前)
转自：

4 条回复

0#
回复此人
无思 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 这种模式可能已在SO上多次发布（有效地添加到并发映射）： </p> <pre> <code> Queue<String> q = map.get(key); if(q == null) { q = new ConcurrentLinkedQueue<String>(); Queue<String> curQ = map.putIfAbsent(key, q); if(curQ != null) { q = curQ; } } q.add(value); </code> </pre> </DIV>

编辑
1#
回复此人
甲基蓝 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 所以你担心线程A和线程B将执行以下操作： </p> <P> <code> thread A: lock ConcurrentHashMap Look for Queue "x" (not found) unlock ConcurrentHashMap create Queue "x" lock ConcurrentHashMap Insert Queue X unlock ConcurrentHashMap Thread B: Lock ConcurrentHashMap (while thread A is in 'create Queue X') look for queue X (not found) unlock ConcurrentHashMap (thread A then gets lock) create Queue "x" v2 lock ConcurrentHashMap Insert Queue X v2 (overwriting the old entry) unlock ConcurrentHashMap </code> </p> <P> 这实际上是一个真正的问题，但通过使AddElementToQueue成为同步方法可以轻松解决这个问题。然后在任何给定时间内AddElementToQueue中只能有一个线程，因此第一个'unlock'和第二个'lock'之间的同步孔关闭。 </p> <P> 从而 </p> <P> <code> public synchronized void addElementToQueue(String key, String value){ </code> </p> <P> 应该解决你的丢失队列问题。 </p> </DIV>

编辑
2#
回复此人
明月清风上善若水自由如风 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果Java 8是一个选项： </p> <pre> <code> public void addElementToQueue(String key, String value) { map.merge(key, new ConcurrentLinkedQueue<>(Arrays.asList(value)), (oldValue, coming) -> { oldValue.addAll(coming); return oldValue; }); } </code> </pre> </DIV>

编辑

登录后才能参与评论