strmusbipcam.py

# Written by Claude Pageau 18 Nov 2022
# Import required libraries
from threading import Thread
import cv2
import time

class CamStream:
    def __init__(self,
                 src=0,
                 size=(320, 240),
                 name="WebcamVideoStream"):
        # initialize the video camera stream and read the first frame
        # from the stream
        self.stream = cv2.VideoCapture(src)
        self.stream.set(3, size[0])
        self.stream.set(4, size[1])
        (self.grabbed, self.frame) = self.stream.read()

        # initialize the thread name
        self.name = name

        # initialize the variable used to indicate if the thread should
        # be stopped
        self.stopped = False

    def start(self):
        # start the thread to read frames from the video stream
        t = Thread(target=self.update, name=self.name, args=())
        t.daemon = True
        t.start()
        return self

    def update(self):
        # keep looping infinitely until the thread is stopped
        while True:
            # if the thread indicator variable is set, stop the thread
            if self.stopped:
                return
            time.sleep(0.001)

    def read(self):
        # return the frame most recently read
        (self.grabbed, self.frame) = self.stream.read()
        return self.frame

    def stop(self):
        # release cameera and stop thread
        self.stream.release()
        time.sleep(2)  # allow time for cam to shut down
        # indicates that the thread should be stopped
        self.stopped = True