| | |
|---|
| | | |
|---|
| | | class MyTradeActionCallback(command_manager.TradeActionCallback): |
|---|
| | | __tradeSimpleApi = TradeSimpleApi() |
|---|
| | | trade_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=20) |
|---|
| | | trade_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=30) |
|---|
| | | |
|---|
| | | def OnTrade(self, client_id, request_id, sk, type_, data): |
|---|
| | | if type_ == 1: |
|---|
| | |
|---|
| | | |
|---|
| | | def run(trade_response_: TradeResponse = None, queue_other_w_l2_r_: multiprocessing.Queue = None, |
|---|
| | | queue_strategy_trade_write_=None, |
|---|
| | | queue_strategy_trade_read=None): |
|---|
| | | queue_strategy_trade_read=None,queue_strategy_trade_read_for_read=None): |
|---|
| | | try: |
|---|
| | | logger_system.info("交易进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"trade 线程ID:{tool.get_thread_id()}") |
|---|
| | |
|---|
| | | |
|---|
| | | global tradeCommandManager |
|---|
| | | tradeCommandManager = command_manager.TradeCommandManager() |
|---|
| | | tradeCommandManager.init(MyTradeActionCallback(), queue_strategy_trade_read) |
|---|
| | | tradeCommandManager.init(MyTradeActionCallback(), queue_strategy_trade_read, queue_strategy_trade_read_for_read) |
|---|
| | | logger_system.info("华鑫交易服务启动") |
|---|
| | | tradeCommandManager.run() |
|---|
| | | except Exception as e: |
|---|
