不修改主类，如何同步Python线程以等待全部启动后执行方法？

嘿，我来帮你搞定这个线程同步的坑！你的问题核心在于Barrier的赋值时机不对，而且没有在所有子线程间共享，导致有些线程拿到的Barrier还是None。加上Python 2.7的threading模块本身没有内置Barrier（这个特性是Python3.2之后才加入的），我们可以用以下方法解决，而且完全不用修改Master类：

核心思路 #

因为不能改Master类，我们只能在子类上做文章：

• 用子类的类级变量存储Barrier，让所有子线程实例共享同一个同步器
• 让Master先创建并启动所有子线程，再给子类的类变量赋值Barrier
• 子线程内部先等待Barrier被初始化完成，再调用wait()实现全线程同步

具体实现代码 #

第一步：实现Python2.7可用的Barrier（如果已有第三方Barrier实现可跳过） #

import threading

class SimpleBarrier:
    def __init__(self, total_threads):
        self.total = total_threads
        self.current = 0
        self.lock = threading.Lock()
        self.ready_event = threading.Event()

    def wait(self):
        with self.lock:
            self.current += 1
            if self.current == self.total:
                # 所有线程都到齐，触发同步事件
                self.ready_event.set()
        # 等待所有线程就绪
        self.ready_event.wait()

第二步：修改子类，使用类级变量共享Barrier #

from threading import Thread

class ChildThread(Thread):
    # 类级变量：所有子线程实例共享同一个Barrier
    shared_barrier = None

    def __init__(self, master):
        super(ChildThread, self).__init__()
        self.master = master

    def run(self):
        # 先等待Master完成Barrier的初始化
        while ChildThread.shared_barrier is None:
            # 短暂休眠避免忙等占用CPU
            threading.sleep(0.01)
        
        # 等待所有子线程都启动并到达同步点
        ChildThread.shared_barrier.wait()
        
        # 现在可以安全调用Master的方法了！
        self.master.target_method()

# 假设你的Master类是固定不可修改的，示例代码如下：
class MasterClass:
    def __init__(self):
        self.child_list = []
        # 创建并启动所有子线程
        for _ in range(5):  # 示例启动5个子线程
            child = ChildThread(master=self)
            self.child_list.append(child)
            child.start()
        
        # 关键操作：所有子线程启动后，初始化子类的共享Barrier
        ChildThread.shared_barrier = SimpleBarrier(len(self.child_list))

    def target_method(self):
        print(f"Master方法被线程 {threading.current_thread().name} 调用")

为什么之前的方案失效？ #

你之前的代码是给每个子线程实例单独赋值barrier，但如果Master是先启动子线程，再遍历赋值，那有些子线程已经跑到if self.barrier is None的判断逻辑了，会自己创建一个独立的Barrier，和其他线程的Barrier不共享，自然无法实现同步。而用类级变量的话，所有线程共享同一个Barrier，不管启动顺序如何，只要Master在最后完成赋值，所有线程都会拿到同一个同步器。

额外注意点 #

• 子线程里的while循环是为了应对Master先启动线程再设置Barrier的场景，确保线程不会因为Barrier未初始化而报错
• 如果你的Master类是先创建所有子线程、赋值完Barrier再启动，那可以去掉while循环，直接调用wait()即可

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