def reset(self):
        """Resets the generator by stopping all processes"""
        self.alive.value = False
        qsize = 0
        try:
            while True:
                self.queue.get(timeout=0.1)
                qsize += 1
        except QEmptyExcept:
            pass
        print("Queue size on reset: {}".format(qsize))
        for i, p in enumerate(self.proc):
            p.join()
        self.proc.clear()
def reset ( self ) : self . alive . value = False qsize = 0 try : while True : self . queue . get ( timeout = 0.1 ) qsize += 1 except QEmptyExcept : pass print ( "Queue size on reset: {}" . format ( qsize ) ) for i , p in enumerate ( self . proc ) : p . join ( ) self . proc . clear ( )
Resets the generator by stopping all processes