如何在多线程类外部调用OpenCV VideoCapture的read函数？

你遇到的Assertion fctx->async_lock failed错误，本质是多线程访问共享资源时的竞态条件导致的。OpenCV的VideoCapture底层依赖FFmpeg的异步解码机制，当子线程在持续写入status、frame这些共享属性，而主线程无同步地直接读取时，会破坏FFmpeg内部的锁机制，触发这个断言错误。另外你的代码还存在初始化阶段属性未就绪就被读取的问题，可能触发AttributeError。

错误核心点 #

1. 无同步的共享资源访问：子线程在update方法中持续更新self.status、self.frame，主线程的while循环直接读取这些变量，没有任何线程同步机制，导致数据竞争。
2. 未处理属性初始化延迟：子线程启动后需要一点时间才能完成第一帧的读取和处理，主线程可能在这些属性还未被赋值时就尝试访问，引发错误。
3. 未处理视频读取失败的情况：当视频读到末尾或者读取失败时，self.image会是None，此时执行cv2.resize会直接崩溃。

修正后的代码 #

我们通过添加threading.Lock同步共享资源，同时加入属性就绪判断和错误处理逻辑来解决问题：

from threading import Thread, Lock
import cv2, time

class VideoStreamWidget(object):
    def __init__(self, src=0):
        self.capture = cv2.VideoCapture(src)
        # 初始化线程锁，用于同步共享资源的读写
        self.lock = Lock()
        # 初始化共享属性，避免未赋值时被访问
        self.status = False
        self.frame = None
        # 启动读取帧的子线程
        self.thread = Thread(target=self.update, args=())
        self.thread.daemon = True
        self.thread.start()

    def update(self):
        # 在子线程中持续读取帧
        while True:
            if self.capture.isOpened():
                # 加锁后读取并处理帧，避免主线程同时访问
                with self.lock:
                    (self.status, self.image) = self.capture.read()
                    if self.status:
                        self.frame = cv2.resize(self.image, (640, 480))
                    else:
                        # 读取失败时退出线程
                        break
            time.sleep(.01)  # 适当休眠降低CPU占用

    # 封装安全的帧获取方法，内部处理锁逻辑
    def get_frame(self):
        with self.lock:
            return self.status, self.frame.copy() if self.status else None

if __name__ == '__main__':
    video_stream_widget1 = VideoStreamWidget(src=r'C:\Users\ab\Documents\Video\ch6.asf')
    # 短暂等待第一帧就绪
    time.sleep(0.1)
    
    while True:
        vflag, image_np = video_stream_widget1.get_frame()
        if vflag:
            print(f"当前帧尺寸: {image_np.shape}")
            # 这里可以添加你的自定义处理逻辑，比如显示帧
            cv2.imshow('frame_1', image_np)
            if cv2.waitKey(1) == ord('q'):
                break
        else:
            print("视频读取失败或已播放完毕")
            break
    
    # 清理资源
    video_stream_widget1.capture.release()
    cv2.destroyAllWindows()

修正说明 #

1. 线程锁同步：用Lock()包裹共享资源的读写操作，确保同一时间只有一个线程能访问status和frame，彻底避免竞态条件。
2. 安全的帧获取方法：封装get_frame方法，外部调用时无需关心同步逻辑，更符合面向对象设计规范。
3. 初始化与延迟处理：初始化时给共享属性赋默认值，主线程启动后短暂休眠等待第一帧就绪，避免AttributeError。
4. 错误处理：当视频读取失败时跳出循环并清理资源，避免无效的无限循环。

内容的提问来源于stack exchange，提问作者Aakash Basu