| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_r: multiprocessing.Queue, order_queues: List[multiprocessing.Queue], |
|---|
| | | transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue, |
|---|
| | | order_ipc_hosts: list) -> None: |
|---|
| | | transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue) -> None: |
|---|
| | | # def test_add_codes(): |
|---|
| | | # time.sleep(5) |
|---|
| | | # # if value: |
|---|
| | |
|---|
| | | order_queue_distribute_manager = CodeQueueDistributeManager(order_queues) |
|---|
| | | transaction_queue_distribute_manager = CodeQueueDistributeManager(transaction_queues) |
|---|
| | | l2_data_upload_manager = L2DataUploadManager(order_queue_distribute_manager, |
|---|
| | | transaction_queue_distribute_manager, market_queue, |
|---|
| | | order_ipc_hosts) |
|---|
| | | transaction_queue_distribute_manager, market_queue) |
|---|
| | | __init_l2(l2_data_upload_manager) |
|---|
| | | l2_data_manager.run_upload_common() |
|---|
| | | l2_data_manager.run_log() |
|---|
