| | |
|---|
| | | tmep_transaction_queue_dict = {} |
|---|
| | | target_codes = set() |
|---|
| | | target_codes_add_time = {} |
|---|
| | | common_queue = queue.Queue() |
|---|
| | | common_queue = queue.Queue(maxsize=1000) |
|---|
| | | |
|---|
| | | |
|---|
| | | # L2上传数据管理器 |
|---|
| | |
|---|
| | | if code not in self.temp_transaction_queue_dict: |
|---|
| | | self.temp_transaction_queue_dict[code] = collections.deque() |
|---|
| | | if code not in self.temp_log_queue_dict: |
|---|
| | | self.temp_log_queue_dict[code] = queue.Queue() |
|---|
| | | self.temp_log_queue_dict[code] = queue.Queue(maxsize=1000) |
|---|
| | | if code not in self.upload_l2_data_task_dict: |
|---|
| | | t1 = threading.Thread(target=lambda: self.__run_upload_order_task(code), daemon=True) |
|---|
| | | t1.start() |
|---|
