-
Notifications
You must be signed in to change notification settings - Fork 0
/
strmusbipcam.py
51 lines (44 loc) · 1.53 KB
/
strmusbipcam.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
# 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