CallbackList()在多线程环境中的使用技巧

CallbackList 是一个可以存储和调用回调函数的列表对象，它提供了一种在多线程环境中处理回调的便捷方式。在多线程环境中使用 CallbackList 需要注意以下几个技巧：

1. 线程安全：在多线程环境中，多个线程可能同时访问和修改 CallbackList 对象。为了确保线程安全，需要使用适当的同步机制来保护 CallbackList 的访问和修改。一种常见的做法是使用锁，比如 threading.Lock 对象，在访问和修改 CallbackList 时获取和释放锁。以下是一个使用锁的例子：

import threading
from collections import Callable

class MyObject:
    def __init__(self):
        self.callbacks = CallbackList()
        self.lock = threading.Lock()

    def register_callback(self, func):
        with self.lock:
            self.callbacks.append(func)

    def do_something(self):
        # do something...

        with self.lock:
            for func in self.callbacks:
                if isinstance(func, Callable):
                    func()

2. 异常处理：在回调函数中可能会发生异常，为了确保不会影响整个多线程环境，需要在每个回调函数的调用处进行异常处理。可以使用 try-except 语句来捕获异常，并根据实际需求进行处理。以下是一个简单的异常处理的例子：

import threading
import traceback

class MyObject:
    def __init__(self):
        self.callbacks = CallbackList()
        self.lock = threading.Lock()

    def register_callback(self, func):
        with self.lock:
            self.callbacks.append(func)

    def do_something(self):
        # do something...

        with self.lock:
            for func in self.callbacks:
                try:
                    func()
                except Exception:
                    traceback.print_exc()

3. 使用示例：下面是一个完整的使用 CallbackList 的例子，演示了在多线程环境中注册回调函数并进行调用的过程。在这个例子中，主线程和工作线程分别注册了两个回调函数，然后主线程调用 do_something 方法触发回调函数的执行。

import threading

class MyObject:
    def __init__(self):
        self.callbacks = CallbackList()
        self.lock = threading.Lock()

    def register_callback(self, func):
        with self.lock:
            self.callbacks.append(func)

    def do_something(self):
        # do something...

        with self.lock:
            for func in self.callbacks:
                func()

def callback1():
    print("Callback 1 executed.")

def callback2():
    print("Callback 2 executed.")

if __name__ == "__main__":
    obj = MyObject()

    t1 = threading.Thread(target=obj.register_callback, args=(callback1,))
    t2 = threading.Thread(target=obj.register_callback, args=(callback2,))

    t1.start()
    t2.start()

    obj.do_something()

运行上述示例代码，可能会得到类似如下的输出：

Callback 1 executed.
Callback 2 executed.

在这个例子中，我们创建了一个 MyObject 对象，然后在主线程和工作线程中注册了两个回调函数，最后调用 do_something 方法执行回调函数。由于使用了 CallbackList，保证了在多线程环境中回调函数的安全调用。