如何实现Python视频播放与代码逻辑的并发执行？

问题场景 #

当前使用OpenCV播放视频时，播放循环会阻塞主线程，导致后续的实时处理代码必须等待视频播放完成才能执行，无法满足并发需求。以下提供两种可行的实现方案：

方案一：使用threading多线程分离播放与逻辑 #

将视频播放逻辑放到子线程中执行，主线程专注处理实时任务，两者互不阻塞。

示例代码 #

import cv2
import threading
import time

# 视频播放线程函数
def play_video(video_path):
    cap = cv2.VideoCapture(video_path)
    while cap.isOpened():
        ret, frame = cap.read()
        if not ret:
            break
        cv2.imshow('Video', frame)
        # 按q退出播放
        if cv2.waitKey(1) & 0xFF == ord('q'):
            break
    cap.release()
    cv2.destroyAllWindows()

# 实时处理逻辑函数
def real_time_processing():
    # 模拟实时处理任务，比如每秒输出一次状态
    count = 0
    while True:
        # 这里可以替换成你的实际处理逻辑
        print(f"实时处理中：第{count}次执行")
        count += 1
        time.sleep(1)
        # 可通过全局变量/事件对象控制线程退出

if __name__ == "__main__":
    # 启动视频播放线程
    video_thread = threading.Thread(target=play_video, args=('video.mp4',))
    video_thread.start()

    # 主线程执行实时处理逻辑
    real_time_processing()

注意事项 #

• 若需要在实时逻辑中处理视频帧，可通过线程安全队列（queue.Queue）在播放线程和主线程之间传递帧数据
• 可设置全局变量或threading.Event对象控制两个线程的退出时机，避免程序僵死

方案二：使用PyQt5实现异步播放与处理 #

PyQt5的事件循环天然支持异步操作，适合需要GUI界面的项目，视频播放和实时逻辑可在不同线程或定时器中执行。

示例代码 #

import sys
import cv2
from PyQt5.QtWidgets import QApplication, QLabel, QWidget, QVBoxLayout
from PyQt5.QtGui import QImage, QPixmap
from PyQt5.QtCore import QThread, pyqtSignal, QTimer

# 视频播放线程
class VideoThread(QThread):
    frame_signal = pyqtSignal(QImage)

    def __init__(self, video_path):
        super().__init__()
        self.video_path = video_path
        self.running = True

    def run(self):
        cap = cv2.VideoCapture(self.video_path)
        while self.running and cap.isOpened():
            ret, frame = cap.read()
            if not ret:
                break
            # 转换OpenCV帧格式为PyQt可用格式
            frame_rgb = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
            h, w, ch = frame_rgb.shape
            bytes_per_line = ch * w
            q_img = QImage(frame_rgb.data, w, h, bytes_per_line, QImage.Format_RGB888)
            self.frame_signal.emit(q_img)
            self.msleep(1)
        cap.release()

    def stop(self):
        self.running = False
        self.wait()

# 主窗口类
class MainWindow(QWidget):
    def __init__(self):
        super().__init__()
        self.setWindowTitle("视频播放+实时处理")
        self.layout = QVBoxLayout()

        # 视频显示标签
        self.video_label = QLabel()
        self.layout.addWidget(self.video_label)

        # 启动视频线程
        self.video_thread = VideoThread('video.mp4')
        self.video_thread.frame_signal.connect(self.update_video_frame)
        self.video_thread.start()

        # 启动实时处理定时器
        self.process_timer = QTimer()
        self.process_timer.timeout.connect(self.do_real_time_processing)
        self.process_timer.start(1000)  # 每秒执行一次

        self.setLayout(self.layout)

    def update_video_frame(self, q_img):
        # 更新视频显示
        self.video_label.setPixmap(QPixmap.fromImage(q_img).scaled(self.video_label.size(), aspectRatioMode=1))

    def do_real_time_processing(self):
        # 替换为你的实时处理逻辑
        print("PyQt实时处理任务执行中...")

    def closeEvent(self, event):
        # 关闭窗口时停止线程和定时器
        self.video_thread.stop()
        self.process_timer.stop()
        event.accept()

if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec_())

优势 #

• 自带GUI界面，可扩展性强
• 线程间通过信号槽通信，线程安全
• 方便集成更多UI控件和复杂实时处理逻辑

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