Python的多線程日志打印混亂問題可以通過以下幾種方式解決:
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()
logging.handlers.QueueHandler
和logging.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()
logging.Logger
對象,通過設置不同的日志級別和日志處理器,將日志消息分別寫入不同的文件或打印到控制臺。示例代碼如下: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()
以上是三種常用的解決多線程日志打印混亂問題的方法,可以根據具體情況選擇適合的方式來解決。