恢复调用分析员并发线程数 由1改为4

dataAnalysisBusiness/algorithm/dataProcessor.py

@@ -75,7 +75,7 @@ class DataProcessor:
 
     def notifyOfTurbine(self,  conf: Contract, turbineCode: str) -> pd.DataFrame:        
         results =[]
-        maxWorkers = 1
+        maxWorkers = 4
         with concurrent.futures.ThreadPoolExecutor(max_workers=maxWorkers) as executor:
             futures = [
                         executor.submit(self.singleTurbineDataNotify,analyst, conf,turbineCode)
@@ -99,7 +99,7 @@ class DataProcessor:
 
     def notifyOfTurbines(self, conf: Contract,turbineCodes) -> pd.DataFrame:
         results =[]
-        maxWorkers = 1
+        maxWorkers = 4
         with concurrent.futures.ThreadPoolExecutor(max_workers=maxWorkers) as executor:
             futures = [
                         executor.submit(self.multiTubineDataNotify,analyst, conf,turbineCodes)