Python 多线程日志错乱的原因
logging.Handler 在多线程环境下可能出现日志错乱，主要原因在于默认的 Handler 实现并非线程安全。多个线程同时调用同一 Handler 的 emit() 方法时，日志内容可能交叉混合，导致输出混乱。
解决方法：使用线程安全的 Handler
Python 标准库中的 logging.handlers.QueueHandler 和 QueueListener 专为解决多线程日志问题设计。通过将日志记录放入队列，由单独的线程处理实际写入操作。
import logging import logging.handlers import queue import threading log_queue = queue.Queue() queue_handler = logging.handlers.QueueHandler(log_queue) logger = logging.getLogger() logger.addHandler(queue_handler) logger.setLevel(logging.INFO) listener = logging.handlers.QueueListener(log_queue, logging.StreamHandler()) listener.start() def worker(): logger.info('Thread log message') threads = [] for _ in range(5): t = threading.Thread(target=worker) threads.append(t) t.start() for t in threads: t.join() listener.stop()方法二：使用锁机制同步 Handler
如果不想使用队列，可以为自定义 Handler 添加线程锁确保线程安全：
import logging import threading class ThreadSafeHandler(logging.Handler): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self.lock = threading.Lock() def emit(self, record): with self.lock: super().emit(record) handler = ThreadSafeHandler() handler.setFormatter(logging.Formatter('%(asctime)s - %(message)s')) logger = logging.getLogger() logger.addHandler(handler) logger.setLevel(logging.INFO)方法三：每个线程使用独立 Handler
为每个线程创建独立的 Handler 实例，避免共享资源竞争：
import logging import threading def get_thread_logger(): handler = logging.StreamHandler() handler.setFormatter(logging.Formatter('%(threadName)s - %(message)s')) logger = logging.getLogger(threading.current_thread().name) logger.addHandler(handler) logger.setLevel(logging.INFO) return logger def worker(): logger = get_thread_logger() logger.info('Thread-specific log') threads = [] for i in range(3): t = threading.Thread(target=worker, name=f'Thread-{i}') threads.append(t) t.start() for t in threads: t.join()注意事项
logging 模块本身是线程安全的，但具体 Handler 实现可能不是。FileHandler 在 Python 3.6+ 中已是线程安全，但某些第三方 Handler 仍需注意。
使用 QueueHandler 会增加少量性能开销，但对大多数应用影响不大。避免在性能关键路径中频繁记录大量日志。
