yandextank/plugins/Bfg/worker.py
def stop(self):
        """
        Say the workers to finish their jobs and quit.
        """
        self.quit.set()
        # yapf:disable
        while sorted([
                self.pool[i].is_alive()
                for i in xrange(len(self.pool))])[-1]:
            time.sleep(1)
        # yapf:enable
        try:
            while not self.task_queue.empty():
                self.task_queue.get(timeout=0.1)
            self.task_queue.close()
            self.feeder.join()
        except Exception as ex:
            logger.info(ex)
def stop(self):
        self.quit.set()
        # yapf:disable
        while sorted([
                self.pool[i].is_alive()
                for i in xrange(len(self.pool))])[-1]:
            time.sleep(1)
        # yapf:enable
        try:
            while not self.task_queue.empty():
                self.task_queue.get(timeout=0.1)
            self.task_queue.close()
            self.feeder.join()
        except Exception as ex:
            logger.info(ex)
def stop ( self ) : self . quit . set ( ) # yapf:disable while sorted ( [ self . pool [ i ] . is_alive ( ) for i in xrange ( len ( self . pool ) ) ] ) [ - 1 ] : time . sleep ( 1 ) # yapf:enable try : while not self . task_queue . empty ( ) : self . task_queue . get ( timeout = 0.1 ) self . task_queue . close ( ) self . feeder . join ( ) except Exception as ex : logger . info ( ex )
Say the workers to finish their jobs and quit.
Say the workers to finish their jobs and quit .