| | |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import msgpack |
|---|
| | | import zmq |
|---|
| | | |
|---|
| | | from huaxin_client import l2_data_transform_protocol |
|---|
| | |
|---|
| | | self.__queue_codes[queue_id].add(code) |
|---|
| | | self.__code_queue_dict[code] = queue_id |
|---|
| | | break |
|---|
| | | # 分配订阅信息 |
|---|
| | | logger_debug.info(f"订阅通道分配：{self.__code_queue_dict}") |
|---|
| | | return [(self.__com_queue_id_object_dict.get(queue_id), self.__queue_codes[queue_id]) for queue_id in |
|---|
| | | self.__queue_codes] |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | queues = [multiprocessing.Queue() for i in range(7)] |
|---|
| | | queues = [multiprocessing.Queue(maxsize=1024) for i in range(7)] |
|---|
| | | manager = TargetCodeProcessManager(queues, 10) |
|---|
| | | counts = [70, 60, 50, 10] |
|---|
| | | for i in range(4): |
|---|
