Created
April 21, 2020 00:51
-
-
Save ammani-prop/cccc2e7cc5a0507dda4252beadb855e0 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# Written by Luis Mesas | |
import threading | |
import time | |
import cv2 | |
# Define video capture class | |
class VideoCaptureAsync: | |
def __init__(self, src=0, width=640, height=480, driver=None): | |
self.src = src | |
if driver is None: | |
self.cap = cv2.VideoCapture(self.src) | |
else: | |
self.cap = cv2.VideoCapture(self.src, driver) | |
self.cap.set(cv2.CAP_PROP_FRAME_WIDTH, width) | |
self.cap.set(cv2.CAP_PROP_FRAME_HEIGHT, height) | |
self.grabbed, self.frame = self.cap.read() | |
self.started = False | |
self.read_lock = threading.Lock() | |
self.thread = None | |
def get(self, var1): | |
return self.cap.get(var1) | |
def set(self, var1, var2): | |
self.cap.set(var1, var2) | |
def start(self): | |
if self.started: | |
print('[!] Asynchroneous video capturing has already been started.') | |
return None | |
self.started = True | |
self.thread = threading.Thread(target=self.update, args=()) | |
self.thread.start() | |
return self | |
def update(self): | |
while self.started: | |
grabbed, frame = self.cap.read() | |
with self.read_lock: | |
self.grabbed = grabbed | |
self.frame = frame | |
def read(self): | |
with self.read_lock: | |
frame = self.frame.copy() | |
grabbed = self.grabbed | |
return grabbed, frame | |
def stop(self): | |
self.started = False | |
self.thread.join() | |
def __exit__(self, exec_type, exc_value, traceback): | |
self.cap.release() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment