dispatcher.py 文件源码

def __init__(self, name, gatewayIDs: List[ModuleID]):
        # call the thread class
        super().__init__()
        self.name = 'Dispatcher ' + name
        self._gatewayIDs = gatewayIDs
        self._routeMap = self._initRouteMap(gatewayIDs)  # type: DefaultDict[ModuleID, ModuleID]
        self._groupMap = {}  # type: DefaultDict[GroupID, List[ModuleID]]
        self._msgCount = 0