| | |
| | | |
| | | |
| | | if __name__ == '__main__': |
| | | st1 = "#" |
| | | for i in range(1000): |
| | | st1 += "#" |
| | | st2 = "#" |
| | | for i in range(10000): |
| | | st2 += "#" |
| | | |
| | | start_time = time.time() |
| | | print(st1) |
| | | print("耗时1:", time.time() - start_time) |
| | | start_time = time.time() |
| | | print(st2) |
| | | print("耗时2:", time.time() - start_time) |
| | | log.close_print() |
| | | # 策略与server间的通信 |
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
| | |
| | | l2Process = multiprocessing.Process(target=huaxin_api.l2_client.run, args=(ptl2_l2, psl2_l2,)) |
| | | l2Process.start() |
| | | # |
| | | tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run,args=(ptl2_trade, pst_trade,)) |
| | | tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade,)) |
| | | tradeProcess.start() |
| | | # L1订阅数据 |
| | | huaxin_api.l1_client.run_async(pl1t_l1) |