Python线程类方法回调无法终止及weakref使用合理性问询

核心原因 #

当回调是Worker类的方法时，线程的执行逻辑大概率持有Worker实例的强引用（比如线程循环里直接通过实例调用方法、或是把实例绑定到了线程函数中）。这会导致即便执行del worker，实例的引用计数依然不为0，垃圾回收无法触发__del__方法，线程也就会持续运行。而全局函数不存在这条强引用链，所以外部引用删除后，GC能正常回收相关资源，线程随即停止。

弱引用思路的合理性 #

用弱引用解决该问题的思路完全合理——本质是切断线程对Worker实例的强引用绑定，让实例能在外部引用被清除时，被垃圾回收器正常回收，进而触发终止逻辑。

WeakValueDictionary的使用正确性 #

是否正确取决于你的具体实现逻辑：

• 如果WeakValueDictionary被用来存储Worker实例，且线程仅持有字典中实例的弱引用（而非直接持有实例本身），每次执行回调前先检查弱引用是否有效，这种用法是正确的。
• 如果只是把实例存入WeakValueDictionary，但线程仍然直接持有实例的强引用（比如线程函数里还是通过self调用方法），那这个字典完全起不到作用，强引用链依然存在，实例无法被GC回收。

正确的弱引用实现示例 #

import weakref
import threading
import time

class Worker:
    def __init__(self):
        self.event_handler = EventHandler(weakref.ref(self))

    def callback(self):
        print("Worker callback executed")

class EventHandler:
    def __init__(self, worker_ref):
        self.worker_ref = worker_ref
        self.running = True
        self.thread = threading.Thread(target=self._run)
        self.thread.start()

    def _run(self):
        while self.running:
            worker = self.worker_ref()
            if not worker:
                self.running = False
                break
            worker.callback()
            time.sleep(1)

    def __del__(self):
        self.running = False
        self.thread.join()

这个实现中，线程仅持有Worker的弱引用，当执行del worker后，实例引用计数归0，GC会回收实例；线程下次循环时检测到弱引用失效，就会自动终止。

替代方案 #

如果不想依赖弱引用和__del__的不确定性（Python中__del__的执行时机并不完全可控），可以给Worker类添加显式的停止方法，比如stop()，内部调用EventHandler的终止逻辑，直接控制线程停止，这种方式更直观可靠。

内容的提问来源于stack exchange，提问作者Pascal