dispatcher.py 文件源码

def __init__(self, code=None, namespace=None, process_target=None, use_caching=False):
        """
        Create a new signal.
        """
        if not process_target:
            process_target = self.process
        self.process_target = process_target

        self.receivers = list()
        self.self_refs = dict()
        self.lock = threading.Lock()

        if code:
            self.code = code
        else:
            self.code = self.Meta.code

        if namespace:
            self.namespace = namespace
        else:
            self.namespace = self.Meta.namespace

        self.use_caching = use_caching
        self.sender_receivers_cache = weakref.WeakKeyDictionary() if use_caching else {}
        self._dead_receivers = False