多进程及时关闭数据库连接

QMT/qmt_real_hlfx.py

@@ -226,6 +226,7 @@ def hlfx(data, stocks, pool_list):
                     m = m - 1
                     if m == 0:
                         df_day.loc[x, 'HL'] = 'H'
+    engine_stock.dispose()
 
 
 
@@ -288,6 +289,7 @@ def bridge(data):
     cursor_pool.execute(sql)
     db_pool.commit()
     print(f'{dt.now()}写入新的results，hlfx_pool更新')
+    engine_hlfx_pool.dispose()
     # hlfx(data, engine_stock, engine_hlfx)
     pass
 
@@ -300,6 +302,7 @@ def prepare():
     results = [x.replace('XSHG', 'SH').replace('XSHE', 'SZ') for x in results]
     print('数据库读取,并转化后缀格式', len(results))
     # print(results[0:10])
+    engine_hlfx_pool.dispose()
     return results
 
 

QMT/real_time.py

@@ -192,6 +192,7 @@ def buy_trader(data):
                     print('买入信号！！！！！！', stock, volume, current_price)
                     order_id = xt_trader.order_stock(acc, stock, xtconstant.STOCK_BUY, volume, xtconstant.LATEST_PRICE, current_price, 'strategy1', 'order_test')
                     print(order_id)
+    engine_hlfx_pool.dispose()
     print('一轮结束了，现在时间是：', dt.now())
 
 
@@ -277,6 +278,7 @@ class MyXtQuantTraderCallback(XtQuantTraderCallback):
 if __name__ == '__main__':
     auth('18616891214', 'Ea?*7f68nD.dafcW34d!')
 
+    mp.freeze_support()
     print("start")
     # 指定客户端所在路径
     path = r'c:\\qmt\\userdata_mini'