| | |
|---|
| | | queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start() |
|---|
| | | |
|---|
| | | # 绑核运行 |
|---|
| | | psutil.Process(l1Process.pid).cpu_affinity([20]) |
|---|
| | | psutil.Process(tradeProcess.pid).cpu_affinity([21, 22]) |
|---|
| | | cpu_indexes = [i for i in range(23, 30)] |
|---|
| | | psutil.Process(os.getpid()).cpu_affinity(cpu_indexes) |
|---|
| | | # psutil.Process(l1Process.pid).cpu_affinity([20]) |
|---|
| | | # psutil.Process(tradeProcess.pid).cpu_affinity([21, 22]) |
|---|
| | | # cpu_indexes = [i for i in range(23, 30)] |
|---|
| | | # psutil.Process(os.getpid()).cpu_affinity(cpu_indexes) |
|---|
| | | # 主进程 |
|---|
| | | createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r, |
|---|
| | | queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w, |
|---|
