code: 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()
docs: Resets the generator by stopping all processes