OpenCV中while循环内无法创建新摄像头连接的问题排查

我正在开发一款可切换摄像头画面的应用，将摄像头功能封装为CamObj类，初始化时创建VideoCapture对象。

• 循环外顺序初始化类实例（如CamObj(0)、CamObj(1)）时，VideoCapture能正常打开
• 但在while循环内通过输入摄像头索引切换实例时，VideoCapture无法正常打开

已尝试的操作：

• 在stop()函数中添加thread.join()
• 增加打印语句确认创建新实例前已完成资源清理
• 测试所有可用摄像头索引
• 尝试通过change_index方法切换索引（仍无效）

附上当前代码：

class CamObj:
    """
    Class that continuously acquires images from a camera.
    """

    def __init__(self, index):
        self.error = False
        self.index = index
        print(self.index, " Camera created")

        self.stream = cv2.VideoCapture(self.index)
        (self.got_frame, self.frame) = self.stream.read()

        if not self.stream.isOpened():
            print(self.index, " NOT OPENED")

        self.running = True
        self.thread = Thread(target=self.get_frames_loop)
        print(self.index , " Camera starting")
        self.thread.start()

    def get_frames_loop(self):
        while self.running:
            if not self.got_frame:
                print(self.index , " NO FRAME")
                self.stop()
            else:
                #print("Running")
                (self.got_frame, self.frame) = self.stream.read()


    def stop(self):
        print(self.index , " Is stopping")
        self.running = False
        print(self.index , " Joining")
        self.thread.join()
        print(self.index , " Releasing")
        self.stream.release()
        print(self.index , " Released")


def run():
    camera = CamObj(0) # good, works
    camera = CamObj(1) # also works
    while True:
        index = input("\n Enter camera index: ")
        camera.stop()
        camera = CamObj(index) # fails to open the capture


# Press the green button in the gutter to run the script.
if __name__ == '__main__':
    run()

尝试过的change_index方法：

def change_index(self, index):
    self.stream.release()
    self.stream = cv2.VideoCapture(self.index)
    if not self.stream.isOpened():
        print(self.index + " NOT OPENED")

问题分析与修复方案 #

核心问题点

1. 输入索引类型错误：input()返回的是字符串，而cv2.VideoCapture需要整数索引，直接传入会导致设备识别失败
2. 线程逻辑缺陷：get_frames_loop中初始帧读取失败时直接调用stop()，可能引发线程阻塞或资源未正确释放
3. change_index参数误用：方法内使用self.index而非传入的index参数，根本没切换到新索引

修复后的完整代码

import cv2
from threading import Thread

class CamObj:
    """
    Class that continuously acquires images from a camera.
    """

    def __init__(self, index):
        # 强制转换索引为整数，处理输入错误
        try:
            self.index = int(index)
        except ValueError:
            print(f"无效摄像头索引: {index}")
            self.error = True
            return
        
        self.error = False
        print(self.index, " 摄像头已创建")

        self.stream = cv2.VideoCapture(self.index)
        # 先检查设备是否打开成功，再尝试读帧
        if not self.stream.isOpened():
            print(self.index, " 设备未打开")
            self.error = True
            return

        (self.got_frame, self.frame) = self.stream.read()

        self.running = True
        # 设置守护线程，主进程退出时自动终止线程
        self.thread = Thread(target=self.get_frames_loop, daemon=True)
        print(self.index , " 摄像头启动")
        self.thread.start()

    def get_frames_loop(self):
        while self.running:
            # 先读帧再判断结果，避免初始帧失败导致重复调用stop
            (self.got_frame, self.frame) = self.stream.read()
            if not self.got_frame:
                print(self.index , " 无法获取帧")
                self.running = False
                break

    def stop(self):
        if self.error:
            return
        print(self.index , " 正在停止")
        self.running = False
        # 给线程添加超时等待，防止无限阻塞
        if self.thread.is_alive():
            self.thread.join(timeout=1)
        print(self.index , " 正在释放资源")
        self.stream.release()
        print(self.index , " 资源已释放")

    def change_index(self, index):
        if self.running:
            self.stop()
        
        try:
            new_index = int(index)
        except ValueError:
            print(f"无效摄像头索引: {index}")
            self.error = True
            return
        
        self.index = new_index
        self.error = False
        self.stream = cv2.VideoCapture(self.index)
        if not self.stream.isOpened():
            print(self.index, " 设备未打开")
            self.error = True
            return
        
        (self.got_frame, self.frame) = self.stream.read()
        self.running = True
        self.thread = Thread(target=self.get_frames_loop, daemon=True)
        print(self.index , " 摄像头启动")
        self.thread.start()


def run():
    camera = CamObj(0) # 正常工作
    camera = CamObj(1) # 正常工作
    while True:
        index = input("\n 输入摄像头索引（输入q退出）: ")
        if index.lower() == 'q':
            camera.stop()
            break
        camera.stop()
        camera = CamObj(index)


if __name__ == '__main__':
    run()

关键修复说明

• 索引类型处理：在初始化和切换方法中强制转换索引为整数，避免字符串输入导致的设备识别问题
• 线程优化：将线程设为守护线程，添加超时等待，调整帧读取逻辑避免线程卡死
• change_index修正：使用传入的新索引参数，确保实际切换到目标摄像头
• 错误增强：增加索引输入错误的提示，提前终止无效流程

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