-
-
Save alierkan/c4c3116db615e7dbcc1fa565c168191c 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