Pythonでのマルチスレッドログ出力の混乱を解決する方法は何ですか？

Pythonのマルチスレッドログ出力の混乱問題は、次の方法で解決できます。

1. 全体のスレッドがログを出力する前に、グローバルなスレッドロックを取得することで、1つのスレッドだけがログを出力することを保証し、他のスレッドはロックが解放されるのを待ってから出力を行います。以下に例を示します。

import threading
import logging

# 创建线程锁
lock = threading.Lock()

def worker():
    # 获取线程锁
    lock.acquire()
    try:
        # 打印日志
        logging.info("Hello, World!")
    finally:
        # 释放线程锁
        lock.release()

# 创建多个线程并启动
threads = []
for i in range(10):
    t = threading.Thread(target=worker)
    threads.append(t)
    t.start()

# 等待所有线程结束
for t in threads:
    t.join()

1. ログハンドラーキューハンドラ
2. ログの処理を行うhandlersの一つであるQueueListener

import logging
import logging.handlers
import threading
import queue

# 创建日志队列
log_queue = queue.Queue()

# 创建日志处理器
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter('%(asctime)s %(levelname)s %(message)s'))

# 创建日志监听器
listener = logging.handlers.QueueListener(log_queue, handler)

def worker():
    # 打印日志到队列
    logging.info("Hello, World!")

# 启动日志监听器线程
listener_thread = threading.Thread(target=listener.start)
listener_thread.daemon = True
listener_thread.start()

# 创建多个线程并启动
threads = []
for i in range(10):
    t = threading.Thread(target=worker)
    threads.append(t)
    t.start()

# 等待所有线程结束
for t in threads:
    t.join()

# 等待日志监听器线程结束
listener_thread.join()

1. ロギング。ロガー

import logging
import threading

def worker():
    # 创建线程专用的日志对象
    logger = logging.getLogger(str(threading.current_thread().ident))
    logger.setLevel(logging.INFO)
    
    # 创建日志处理器
    handler = logging.StreamHandler()
    handler.setFormatter(logging.Formatter('%(asctime)s %(levelname)s %(message)s'))
    logger.addHandler(handler)
    
    # 打印日志
    logger.info("Hello, World!")

# 创建多个线程并启动
threads = []
for i in range(10):
    t = threading.Thread(target=worker)
    threads.append(t)
    t.start()

# 等待所有线程结束
for t in threads:
    t.join()

上記は、多重スレッドでのログ出力の混乱を解消するための一般的な方法の3つです。具体的な状況に応じて適切な方法を選択して解決できます。