def __init__ (self, path, queue_size = 128): self.stream = cv2.VideoCapture(path) self.exit = False self.queue = Queue(maxsize=queue_size)