>  Q&A  >  본문

java - 多线程并发情况下Map.containsKey() 判断有问题

有下面一段代码:

package test;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

public class TestContain extends Thread{

       private final String key = "key";
    
       private final static ConcurrentMap<String, Object> locks = new ConcurrentHashMap<>();
        
        private static Object getLock(String lockName) {
            if (!locks.containsKey(lockName)) {
                //这一句会存在并发问题
                locks.put(lockName, new String("我是值"));
                System.out.println("加了一次");
            }
            return locks.get(lockName);
        }
        
        @Override
        public void run() {
            getLock(this.key);
        };
        
        public static void main(String[] args) {
            for (int i = 0; i < 20; i++) {
                new TestContain().start();;
            }
        }
}

输出结果:

加了一次
加了一次
加了一次

表明了Map.containsKey() 在多线程的情况下会判断不准确。

这是为什么呢? 有什么方法改进呢?

黄舟黄舟2744일 전1150

모든 응답(3)나는 대답할 것이다

  • PHPz

    PHPz2017-04-18 10:51:53

    ConcurrentHashMap의 문서에

    단락이 있습니다.

    검색 작업(<tt>get</tt> 포함)은 일반적으로 차단되지 않으므로
    업데이트 작업(

    포함)과 겹칠 수 있습니다.

    putremove) 시작됩니다.
    내부의 get 메소드는 잠기지 않으며, get 메소드는 가장 최근에 완료된 업데이트의 값만 가져옵니다.
    그래서 주제 메서드의

    에는 스레드 안전성을 보장하는 잠금 장치가 없습니다. 그리고

    의 사용 시나리오는 업데이트 작업이 한 번만 수행되도록

    을 사용하는 것이 아니라

    을 사용하여 보장하는 것 같습니다. locks.containsKey(lockName)

    회신하다
    0
  • 高洛峰

    高洛峰2017-04-18 10:51:53

    ConcurrentMap은 여러 작업이 아닌 단일 작업의 원자성을 보장합니다.

    getLock 함수에는 여러 작업이 포함되어 있습니다. ConcurrentMap은 동기화 범위를 확장할 수 없습니다. getLock 잠금을 직접 구현해야 합니다.

    회신하다
    0
  • 迷茫

    迷茫2017-04-18 10:51:53

    putIfAbsent 메소드를 사용하세요.

    회신하다
    0
  • 취소회신하다