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)