def run()

in leda_python/refactoring/thread.py [0:0]

• 16 lines of code
• 4 McCabe index (conditional complexity)

    def run(self):
        '''
		重构run 方法
		'''
        while (True):
            if (True == self.stopFlag):
                break

            try:
                _logger.debug("")
                _logger.debug("getting ruleTask from dbusThreadPool queue...")
                func, kwargs = self.taskQueue.get(block=True, timeout=10)
                func(**kwargs)
            except queue.Empty:
                _logger.debug("dbusThreadPool Queue is empty and have no ruleTask in the queue")
            except:
                _logger.exception("dbusThreadPool: task exec err#####")