    def onDispatch(reqmsg):
        '''
        @brief: 分配响应报文到对应的回调函数
        @param queue: 有pop()的类，用于提取待处理数据
        @type queue: AsyncProcThread
        @return: None
        @rtype: None
        '''
        raise NotImplementedError()
@brief: 分配响应报文到对应的回调函数
@param queue: 有pop()的类，用于提取待处理数据
@type queue: AsyncProcThread
@return: None
@rtype: None
biliup/Danmaku/tars/__async.py