Thread-sichere Methode zur Berechnung des gleitenden Durchschnitts

Question

Ich habe eine Bibliothek, die HTTP-Anrufe zu meinem Dienst macht. Ich habe versucht, den durchschnittlichen Durchschnitt meiner Dienste zu berechnen.

Hier ist die Kernlogik von, wie ich "laufenden Durchschnitt" errechne.

import java.math.BigDecimal; 
import java.math.RoundingMode; 
import java.util.LinkedList; 
import java.util.Queue; 

public class MovingAverage { 

    private final Queue<BigDecimal> window = new ArrayDeque<BigDecimal>(); 
    private final int period; 
    private BigDecimal sum = BigDecimal.ZERO; 

    public MovingAverage(int period) { 
     this.period = period; 
    } 

    public void add(BigDecimal num) { 
     sum = sum.add(num); 
     window.add(num); 
     if (window.size() > period) { 
      sum = sum.subtract(window.remove()); 
     } 
    } 

    public BigDecimal getAverage() { 
     if (window.isEmpty()) return BigDecimal.ZERO; 
     BigDecimal divisor = BigDecimal.valueOf(window.size()); 
     return sum.divide(divisor, 2, RoundingMode.HALF_UP); 
    } 
} 

Ist dieser Code thread sicher, weil dies von Multithread-Programm aufgerufen wird? Wenn nicht, wie kann ich das Multithread machen.

Ich möchte sicherstellen, dass diese Berechnung des laufenden Durchschnitts schnell ist, da diese Bibliothek unter sehr hoher Last läuft, so dass dies die Gesamtlatenz nicht erhöhen sollte. Auch ich bezweifle, ich brauche sogar BigDecimal hier, double oder long könnte hier funktionieren.

Answer 1

ist dieser Code nicht Thread-sicher vorstellen, nächste Folge:

initial state: MovingAverage queue is empty 
thread 1: calls add(1), sum is 1, window size is 1 
thread 2: calls add(1), pauses after sum = sum.add(num), sum is 2, window size is 1 
thread 1: calls getAverage, it will return 2/1 = 2 

ein weiterer Anwendungsfall:

thread 1: calls add(1), pauses after sum.add(num), but before sum = 
thread 2: calls add(1), sets sum to 1 
thread 1: continues, overwrites sum with 1, but should be 2, as windows size is updated to 2 

der einfachste Weg, um es sicher zu betreten - es fügt synchronized vor jedem Verfahren, aber wird die Ausführung verlangsamen

Answer 2

Warum verwenden Sie nicht http://mvnrepository.com/artifact/com.codahale.metrics? Erstellen Sie dann die Metrikerfassung und verwenden Sie zum Beispiel das Histogramm. Es wird gibt Ihnen Durchschnitt und mehr (p99, P999)

MetricRegistry metricRegistry = new MetricRegistry(); 
Histogram histogram = metricRegistry.histogram("stats"); 

Und dann in dem Code ein:

histogram.update(operationTimeInMilliseconds)