| | |
|---|
| | | queue_strategy_w_trade_r_for_read)) |
|---|
| | | tradeProcess.start() |
|---|
| | | # 此处将L2的进程与策略进程合并 |
|---|
| | | # L2 |
|---|
| | | # l2Process = multiprocessing.Process( |
|---|
| | | # target=huaxin_client.l2_client.run, |
|---|
| | | # args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts,huaxin_trade_server.my_l2_data_callback)) |
|---|
| | | # l2Process.start() |
|---|
| | | |
|---|
| | | # 测试L2单独进程 |
|---|
| | | |
|---|
| | | if True: |
|---|
| | | __create_l2_subscript() |
|---|
| | | else: |
|---|
| | | # 将L2的进程改为线程执行 |
|---|
| | | threading.Thread(target=huaxin_client.l2_client.run, args=( |
|---|
| | | queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start() |
|---|
