Forráskód Böngészése

减少分析员并发执行数,并发数量由4改为1

zhouyang.xie 2 hónapja
szülő
commit
e2a7bd052d
1 módosított fájl, 2 hozzáadás és 2 törlés
  1. 2 2
      dataAnalysisBusiness/algorithm/dataProcessor.py

+ 2 - 2
dataAnalysisBusiness/algorithm/dataProcessor.py

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