1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| import multiprocessing
| import queue
| import threading
| import time
|
| from huaxin_client import l2_data_manager
| from log_module import async_log_util
| from log_module.log import logger_debug
|
| __queue = queue.Queue()
|
| if __name__ == "__main__":
| while True:
| data = __queue.get()
| print("数据:", data)
|
|