    def initialize(self, queue):
        '''
        @brief: 使用AsyncProcThreadRunner前必须调用此函数
        @param queue: 有pop()的类，用于提取待处理数据
        @type queue: AsyncProcThread
        @return: None
        @rtype: None
        '''
        tarsLogger.debug('AsyncProcThreadRunner:initialize')
        self.__procQueue = queue
@brief: 使用AsyncProcThreadRunner前必须调用此函数
@param queue: 有pop()的类，用于提取待处理数据
@type queue: AsyncProcThread
@return: None
@rtype: None
biliup/Danmaku/tars/__async.py