修改回多线程计算

FinHackCN · Jan 18, 2024 · 07b0f60 · 07b0f60
1 parent dbb45d3
commit 07b0f60
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/finhack/core/command/finhack b/finhack/core/command/finhack
@@ -24,4 +24,3 @@ if __name__ == '__main__':
         atexit.register(Utils.auto_exit) # 注册退出函数
         core.do_action()
 
-
diff --git a/finhack/core/core.py b/finhack/core/core.py
@@ -137,7 +137,7 @@ def generate_args(self):
         self.parser=parser
         return parser
 
-        
+
     #生成参数
     def parse_args(self):
         args, unknown = self.parser.parse_known_args() 

diff --git a/finhack/factor/default/indicatorCompute.py b/finhack/factor/default/indicatorCompute.py
@@ -72,10 +72,10 @@ def split_list_n_list(origin_list, n):
         for code_list in code_lists:
             with ProcessPoolExecutor(max_workers=n) as pool:
                 for ts_code in code_list:
-                    indicatorCompute.computeListByStock(ts_code,list_name=list_name,where='',factor_list=factor_list,c_list=c_list,pure=True,check=False,df_price=pd.DataFrame(),db='tushare')
+                    #indicatorCompute.computeListByStock(ts_code,list_name=list_name,where='',factor_list=factor_list,c_list=c_list,pure=True,check=False,df_price=pd.DataFrame(),db='tushare')
 
-        #             mytask=pool.submit(indicatorCompute.computeListByStock,ts_code,list_name,'',factor_list,c_list,True,False)
-        #             tasklist.append(mytask)
+                    mytask=pool.submit(indicatorCompute.computeListByStock,ts_code,list_name,'',factor_list,c_list,True,False)
+                    tasklist.append(mytask)
 
         # wait(tasklist,return_when=ALL_COMPLETED)
         Log.logger.info(list_name+' computed')
Original file line number	Diff line number	Diff line change
Expand Up		@@ -24,4 +24,3 @@ if __name__ == '__main__':
		atexit.register(Utils.auto_exit) # 注册退出函数
		core.do_action()