public class VanishingMean{
private Number[] values; //archiv mit zahlen, (halten wir's mal etwas allgemeiner)
private double sum; //braucht man nicht jedes mal komplett neuzuberechnen
private boolean rewriting; //bei der ersten runde false, danach immer true
private int currentPointer; //aktueller index, damit die ältesten überschrieben werden
private int unrefreshed; //wie lange wurde nix mehr neuberechnet?
private final int REFRESH_LIMIT=10000; //nach so vielen schritten wird alles neuberechnet, um rundungsfehler klein zu halten
public VanishingMean(int maxValues){
values=new Number[maxValues];
reset();
}
// alles neustarten
public void reset(){
for(int i=0; i<values.length; i++) values[i]=0;
sum=0;
rewriting=false;
currentPointer=0;
unrefreshed=0;
}
// alle paar tausend mal die summe komplett neuberechnen, um auf dauer rundungsfehler zu vermeiden
public void refresh(){
sum=0;
for(Number n:values){
sum+=n.doubleValue();
}
unrefreshed=0;
}
// zahl eingeben, statistik ausgeben
public double feed(Number n){
sum+=n.doubleValue()-values[currentPointer].doubleValue(); //alten wert abziehen, neuen drufaddieren
values[currentPointer]=n; //ins "archiv" legen, um später zu löschen
if(++currentPointer>=values.length){
rewriting=true;
currentPointer=0;
if(++unrefreshed>REFRESH_LIMIT){
refresh();
}
}
if(rewriting){
return sum/values.length;
}else{
return sum/currentPointer;
}
}
// kleiner test mit so einer art "gedämpften statistikschwingung"
private static String bar(int h){
String res="#";
for(int i=0; i<h; i++,res+="|");
return res;
}
public static void main(String... _){
VanishingMean v=new VanishingMean(200);
double output,input;
for(int i=0; i<500; i++){
input=(Math.cos(i/5d)+1)*50;
System.out.printf("feeding: %7.2f output: %7.2f %s\n",input,(output=v.feed(input)),bar((int)output));
}
}
}
