    def initialize(self, nrunner=3):
        '''
        @brief: 使用AsyncProcThread前必须先调用此函数
        @param nrunner: 异步线程个数
        @type nrunner: int
        @return: None
        @rtype: None
        '''
        tarsLogger.debug('AsyncProcThread:initialize')
        if self.__initialize:
            return
        self.__nrunner = nrunner
        self.__queue = queue.Queue()
        self.__initialize = True
@brief: 使用AsyncProcThread前必须先调用此函数
@param nrunner: 异步线程个数
@type nrunner: int
@return: None
@rtype: None
biliup/Danmaku/tars/__async.py