| | |
|---|
| | | cancel_order(1, "000333", '123123', orderRef=order_ref, blocking=False) |
|---|
| | | |
|---|
| | | |
|---|
| | | queue_strategy_w_trade_r_for_read = None |
|---|
| | | queue_strategy_w_trade_r = None |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(): |
|---|
| | | global queue_strategy_w_trade_r_for_read, queue_strategy_w_trade_r |
|---|
| | | queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_read = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue() |
|---|
| | | order_ipc_addr, cancel_order_ipc_addr = "ipc://trade_order_ls.ipc", "ipc://trade_order_ls_cancel.ipc" |
|---|
| | | trade_process = multiprocessing.Process( |
|---|
