Threading-based rtsp reader

rtsp_threaded_tracker.py

import cv2 
from concurrent.futures import ThreadPoolExecutor
from redis import Redis

redis_cache = Redis('127.0.0.1')

class RealTimeTracking(object):
    def __init__(self, src):

        self.vdo = cv2.VideoCapture(self.args.input)
        self.status, self.frame = None, None
        self.output_frame = None
        self.thread = ThreadPoolExecutor(max_workers=1)
        self.thread.submit(self.update)

    def update(self):
        while True:
            if self.vdo.isOpened():
                (self.status, self.frame) = self.vdo.read()

    def run(self):
        print('streaming started ...')
        while True:
            try:
                redis_cache.set('frame', frame_to_bytes)
            except AttributeError:
                pass