bus.py 文件源码

def __init__(self, worker_factory=WorkerThread):
        self.__listeners = defaultdict(weakref.WeakSet)
        self.__listener_lock = RWLock()

        self.__workers = {}
        for worker_name in event_ids.EVENT_THREAD_NAMES:
            if worker_name != event_ids.EVENT_THREAD__NOW:
                self.__workers[worker_name] = worker_factory(worker_name)