Python守护线程详解

什么是守护线程？

在Python中，守护线程具有以下特点：

• 守护线程在后台运行，提供非关键服务
• 当所有非守护线程结束时，守护线程会被强制终止
• 守护线程不能阻止程序退出
• 适用于执行支持性任务，如日志记录、监控等

守护线程 vs 普通线程

创建守护线程

在Python中，创建守护线程有两种方式：

1. 在线程启动前设置daemon属性

import threading
import time

def daemon_task():
    while True:
        print("守护线程正在运行...")
        time.sleep(1)

# 创建线程并设置为守护线程
d_thread = threading.Thread(target=daemon_task)
d_thread.daemon = True  # 设置为守护线程
d_thread.start()

# 主线程执行其他任务
time.sleep(3)
print("主线程结束，守护线程将被终止")

2. 使用daemon参数创建线程

import threading
import time

def daemon_job():
    count = 0
    while True:
        print(f"守护线程执行计数: {count}")
        count += 1
        time.sleep(0.5)

# 直接创建守护线程
daemon_thread = threading.Thread(target=daemon_job, daemon=True)
daemon_thread.start()

# 主线程工作
print("主线程开始工作...")
time.sleep(2)
print("主线程工作完成，程序退出")

守护线程的应用场景

使用守护线程的注意事项

完整示例：带守护线程的日志系统

import threading
import time
import logging
from queue import Queue

# 设置日志
logging.basicConfig(level=logging.INFO)

class DaemonLogger:
    def __init__(self):
        self.log_queue = Queue()
        self.log_thread = threading.Thread(target=self.process_logs, daemon=True)
        self.log_thread.start()
        
    def log(self, message):
        """添加日志到队列"""
        self.log_queue.put(message)
        
    def process_logs(self):
        """守护线程：处理日志队列中的消息"""
        while True:
            if not self.log_queue.empty():
                message = self.log_queue.get()
                logging.info(f"[守护线程] 记录日志: {message}")
            time.sleep(0.5)

# 使用日志系统
logger = DaemonLogger()

# 主程序
def main():
    for i in range(5):
        logger.log(f"主程序日志条目 {i+1}")
        print(f"主程序正在执行任务 {i+1}/5")
        time.sleep(1)
    print("主程序执行完毕，即将退出")

if __name__ == "__main__":
    main()