대기열을 사용하는 Java의 동시 이동 평균 창?

Question

안녕하세요, ConcurrentLinkedQueue를 사용하여 Java에서 이동 평균 창 (MAW) 데이터 구조를 만들고 있습니다. MAW는 동시에 여러 스레드에서 호출 할 수 있으므로 코드가 스레드 안전하다는 것을 확인해야합니다.이 작업을 수행 할 수있는 유일한 방법은 (잠금을 대기열로 사용하는) 동기화 된 코드 블록을 추가하는 것입니다 방법 :

final Queue<Double> myQ = new ConcurrentLinkedQueue<Double>(); 
volatile double total; 
volatile int count; 

추가 방법에있어서 나는이 :

는

synchronized (myQ) 
{ 
    if (myQ.offer(value)) 
    { 
     total += value; 
     count++; 
    } 
    if (size > window) 
    { 
     total -= myQ.poll(); 
     count--; 
    } 
    movingAvg = total/count; 
} 

나는 동기화 된 코드 블록을 가지고 있지 라운드 어쨌든 표시되지 않는 이유는 무엇입니까?

감사

Answer 1

당신이 약간 잘못된 값을 받고으로 확인하지 않는 한 나는 방법을 생각할 수 없다. 한편

, 가장 성능 의식 구현 중 하나는 너무 잠금 ( the metrics library)를 사용합니다.

잠금 획득은 JDK6 이후 매우 빠른 얻었다. 내가 너라면 나 그냥 자물쇠를 쓸거야.