동시에 액세스 할 때 트리 맵의 중복 키

Question

이 코드에서 동시성 오류를 찾을 수 있습니까? 이 코드는 한 스레드에서 완벽하게 작동하지만 두 스레드를 동시에 시작하고 addScore 메서드를 호출하면 트리 맵에 중복 요소가 추가됩니다.

class User implements Runnable 
{ 

    private ScoreServiceImpl scoreService=ScoreServiceImpl.getInstance(); 

    CountDownLatch latch; 
    public User(CountDownLatch latch) 
    { 
     this.latch = latch; 
    } 

    @Override 
    public void run() { 


     for(int i=0;i<5;i++) { 
      scoreService.addScore(3,Integer.parseInt(Thread.currentThread().getName()),ThreadLocalRandom.current().nextInt(50000)); 
     } 
     System.out.println(scoreService.getHighScoreList(3)); 
    } 
} 

그리고 만들 수있는 주요 방법 : 이것은 사용자 제작 요청을 시뮬레이션하기 위해 사용하고 코드가

public final class UserHighScore implements Comparable<UserHighScore>{ 

    private final int userId; 
    private final int value; 

    public UserHighScore(int userId, int value) { 
     this.userId = userId; 
     this.value = value; 
    } 

    public int getUserId() { 
     return userId; 
    } 

    public int getValue() { 
     return value; 
    } 

    @Override 
    public boolean equals(Object obj) { 
     if (obj == this) return true; 
     if (!(obj instanceof UserHighScore)) { 
      return false; 
     } 
     UserHighScore userHighScore = (UserHighScore) obj; 
     return userHighScore.userId==userId; 
    } 

    @Override 
    public int compareTo(UserHighScore uh) { 
     if(uh.getUserId()==this.getUserId()) return 0; 
     if(uh.getValue()>this.getValue()) return 1; 
     return -1; 
    } 
} 

다음과 같이

comparedTO의 오버라이드를 가진 POJO이다 스레드는 다음과 같습니다 :

public static void main(String[] args) throws InterruptedException { 

    SpringApplication.run(RestclientApplication.class, args); 

    CountDownLatch latch = new CountDownLatch(1); 
    User user1=new User(latch); 
    User user2=new User(latch); 
    Thread t1=new Thread(user1); 
    Thread t2=new Thread(user2); 
    t1.setName("1"); 
    t2.setName("2"); 
    t1.start(); 
    t2.start(); 
    //latch.countDown(); 
} 

Answer 1

당신의 compareTo는 실수입니다. 당신은이 가운데 첫 번째에있는 사람을 확인, 분할에 의해 작업을 설정이

ScoreServiceImpl.getInstance().addScore(0,1,4); 
    ScoreServiceImpl.getInstance().addScore(0,1,12); 
    ScoreServiceImpl.getInstance().addScore(0,0,10); 
    ScoreServiceImpl.getInstance().addScore(0,0,3); 

나무처럼 뭔가 같은 결과는 단일 스레드받을 정복 할 수 있습니다. (1, 4가 될 것입니다) userIds가 일치하지 않으므로 비교하지 않고 값을 비교합니다. 그것이 남아 사라했을 아이디를 비교했지만 대신 한

당신은 하나 항상 두 값을 비교할 수 있습니다

또는 항상의 사용자 ID와 권리만을 비교 항목을 가면 단지에 비교 userId를하지만 당신은 할 수 '앞뒤로 전환하지 마라.

@Override 
public int compareTo(UserHighScore uh) { 
    return Integer.compare(userId, uh.userId); 
}