From 1ff185866bcf0796d2367699bc000abb326360d5 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 九月 2023 17:02:51 +0800
Subject: [PATCH] 交易设置独立进程/删除trade_client_server/记录L2逐笔委托日志
---
huaxin_client/command_manager.py | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/huaxin_client/command_manager.py b/huaxin_client/command_manager.py
index aec509d..76ccc61 100644
--- a/huaxin_client/command_manager.py
+++ b/huaxin_client/command_manager.py
@@ -65,7 +65,7 @@
class TradeCommandManager:
trade_client_dict = {}
_instance = None
- process_command_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=20)
+ process_command_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=30)
def __new__(cls, *args, **kwargs):
if not cls._instance:
@@ -130,9 +130,9 @@
val = pipe_strategy.recv()
if val:
val = json.loads(val)
- # print("run_process_command", val)
_type = val["type"]
- threading.Thread(target=lambda: cls.process_command(_type, None, val), daemon=True).start()
+ cls.process_command_thread_pool.submit(lambda: cls.process_command(_type, None, val))
+
except Exception as e:
logger_local_huaxin_trade_debug.exception(e)
logging.exception(e)
--
Gitblit v1.8.0