| | |
|---|
| | | time.sleep(10) |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_r: multiprocessing.Queue, order_queues: List[multiprocessing.Queue], |
|---|
| | | transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue, data_callbacks:list) -> None: |
|---|
| | | |
|---|
| | | def run(queue_r: multiprocessing.Queue, data_callbacks: list) -> None: |
|---|
| | | logger_system.info("L2进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"l2_client 线程ID:{tool.get_thread_id()}") |
|---|
| | | try: |
|---|
| | |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | # 初始化 |
|---|
| | | order_queue_distribute_manager = CodeQueueDistributeManager(order_queues) |
|---|
| | | transaction_queue_distribute_manager = CodeQueueDistributeManager(transaction_queues) |
|---|
| | | data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks) |
|---|
| | | l2_data_upload_manager = L2DataUploadManager(order_queue_distribute_manager, |
|---|
| | | transaction_queue_distribute_manager, market_queue, data_callback_distribute_manager) |
|---|
| | | l2_data_upload_manager = L2DataUploadManager(data_callback_distribute_manager) |
|---|
| | | __init_l2(l2_data_upload_manager) |
|---|
| | | l2_data_manager.run_upload_common() |
|---|
| | | l2_data_manager.run_log() |
|---|
