Changes:小于窗口数的增加逻辑写完

average.py

@@ -3,14 +3,16 @@ import json
 import ray
 
 @ray.remote
-class step(algorithm):
+class average(algorithm):
     def __init__(self):
         self.config_dict_ = None
         self.config_ = None
         self.average_number_ = 10
         self.present_number_ = 0
         self.window_1_ = []
-        self.window_2_ = []
+        self.sum = 0
+        self.average = 0
+
 
     def set_config(self, config):
         self.config_ = config
@@ -24,7 +26,12 @@ class step(algorithm):
         self.present_number_ = len(self.window_1_)
         if self.present_number_ < self.average_number_:
             self.window_1_.append(value)
-            self.window_2_.append(value)
             return
         else:
-            return value * self.amplitude_base_
+            self.sum = 0
+            for i in self.window_1_:
+                self.sum = self.sum + i
+            self.average = self.sum / len(self.window_1_)
+            del self.window_1_[0]
+            self.window_1_.append(value)
+            return self.average