| | |
|---|
| | | threading.Thread(target=lambda: self.__create_ipc_server(host), daemon=True).start() |
|---|
| | | |
|---|
| | | # 接收L2数据 |
|---|
| | | def receive_l2_data(self, order_queues, transaction_queues, market_queue, order_ipc_hosts): |
|---|
| | | def receive_l2_data(self, order_queues, transaction_queues, market_queue): |
|---|
| | | # TODO 暂时不通过队列接收数据 |
|---|
| | | # for q in order_queues: |
|---|
| | | # t1 = threading.Thread(target=lambda: self.__recive_l2_orders(q), daemon=True) |
|---|
| | |
|---|
| | | t2.start() |
|---|
| | | t3 = threading.Thread(target=lambda: self.__recive_l2_markets(market_queue), daemon=True) |
|---|
| | | t3.start() |
|---|
| | | # 接收订单hosts |
|---|
| | | if not constant.is_windows(): |
|---|
| | | self.__create_ipc_server_hosts(order_ipc_hosts) |
|---|
| | | |
|---|
| | | def get_active_count(self, type_): |
|---|
| | | expire_time = time.time() - 5 |
|---|
