| | |
|---|
| | | |
|---|
| | | def run(queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_read, |
|---|
| | | order_queues, transaction_queues, |
|---|
| | | market_queue, queue_l1_trade_w_strategy_r): |
|---|
| | | market_queue, queue_l1_trade_w_strategy_r, order_ipc_hosts): |
|---|
| | | logger_system.info(f"trade_server 线程ID:{tool.get_thread_id()}") |
|---|
| | | try: |
|---|
| | | # 执行一些初始化数据 |
|---|
| | |
|---|
| | | # 监听L2数据 |
|---|
| | | global l2DataListenManager |
|---|
| | | l2DataListenManager = L2DataListenManager(my_l2_data_callback) |
|---|
| | | l2DataListenManager.receive_l2_data(order_queues, transaction_queues, market_queue) |
|---|
| | | l2DataListenManager.receive_l2_data(order_queues, transaction_queues, market_queue, order_ipc_hosts) |
|---|
| | | |
|---|
| | | # 启动交易服务 |
|---|
| | | huaxin_trade_api.run_pipe_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, |
|---|
