| | |
|---|
| | | 'OrderTime': '13000015', |
|---|
| | | 'MainSeq': 2, 'SubSeq': 6739148, 'OrderNO': 5512467, 'OrderStatus': 'D'}, 0) |
|---|
| | | |
|---|
| | | queue_r = multiprocessing.Queue() |
|---|
| | | queue_r = multiprocessing.Queue(maxsize=1024) |
|---|
| | | order_queues = [] |
|---|
| | | transaction_queues = [] |
|---|
| | | market_queue = multiprocessing.Queue() |
|---|
| | | market_queue = multiprocessing.Queue(maxsize=1024) |
|---|
| | | for i in range(20): |
|---|
| | | order_queues.append(multiprocessing.Queue()) |
|---|
| | | transaction_queues.append(multiprocessing.Queue()) |
|---|
| | | order_queues.append(multiprocessing.Queue(maxsize=1024)) |
|---|
| | | transaction_queues.append(multiprocessing.Queue(maxsize=1024)) |
|---|
| | | threading.Thread(target=test_add_codes).start() |
|---|
| | | |
|---|
| | | run(queue_r, order_queues, transaction_queues, market_queue) |
|---|
