python-opencv多线程

import cv2 def capture_thread(video_path, frame_buffer, lock): print("capture_thread start") vid = cv2.VideoCapture(video_path) if not vid.isOpened(): raise IOError("Couldn't open webcam or video") while True: return_value, frame = vid.read() if return_value is not True: break cv2.waitKey(25) lock.acquire() frame_buffer.push(frame) lock.release() def play_thread(frame_buffer, lock): print("detect_thread start") print("detect_thread frame_buffer size is", frame_buffer.size()) while True: if frame_buffer.size() > 0: lock.acquire() frame = frame_buffer.pop() lock.release() cv2.imshow("result", frame) if cv2.waitKey(1) & 0xFF == ord('q'): break