如何在类内部封装并管理多个线程实例-Python教程-PHP中文网

如何在类内部封装并管理多个线程实例

本文介绍如何将多线程逻辑完全封装进 python 类中，使每个对象自主启动和管理两个并发线程，避免主线程中重复创建和调度线程，提升代码复用性与可维护性。

在面向对象的多线程编程中，一个常见需求是：为每个业务实体（如设备、任务、客户端）创建独立的对象实例，并让每个实例内部并发执行两项职责（例如数据采集 + 状态上报）。若将线程创建逻辑全部暴露在主模块中（如原始示例），会导致对象与线程耦合松散、初始化繁琐、难以扩展。理想方案是将线程生命周期（启动、等待、清理）内聚于类本身。

以下是一个专业、健壮的实现方式：

import threading
import time

class MyObject:
    def __init__(self, item_id):
        self.item_id = item_id
        # 可选：预分配线程引用，提高可读性与调试友好性
        self.thread1 = None
        self.thread2 = None

    def func_one(self):
        print(f"[{self.item_id}] func_one started")
        time.sleep(1.5)  # 模拟耗时操作
        print(f"[{self.item_id}] func_one completed")

    def func_two(self):
        print(f"[{self.item_id}] func_two started")
        time.sleep(1.0)
        print(f"[{self.item_id}] func_two completed")

    def run_threads(self):
        """启动本对象关联的两个线程；线程目标为实例方法，自动绑定 self"""
        self.thread1 = threading.Thread(target=self.func_one, name=f"{self.item_id}-func1")
        self.thread2 = threading.Thread(target=self.func_two, name=f"{self.item_id}-func2")

        # 推荐设置 daemon=False（默认），确保主线程退出前子线程完成工作
        # 若需后台守护行为，可显式设为 daemon=True（但 join() 将被忽略）
        self.thread1.start()
        self.thread2.start()

    def join_threads(self):
        """阻塞等待本对象的两个线程全部结束"""
        if self.thread1 and self.thread1.is_alive():
            self.thread1.join()
        if self.thread2 and self.thread2.is_alive():
            self.thread2.join()

    def is_running(self):
        """辅助方法：检查当前对象是否仍有活跃线程"""
        return (self.thread1 and self.thread1.is_alive()) or \
               (self.thread2 and self.thread2.is_alive())

使用时极为简洁：

# 创建多个独立实例
obj1 = MyObject("item-01")
obj2 = MyObject("item-02")

# 启动各自线程 —— 完全解耦于主线程调度逻辑
obj1.run_threads()
obj2.run_threads()

# 等待所有工作完成
obj1.join_threads()
obj2.join_threads()

print("All objects finished.")

✅ 关键设计优势：