如何循环播放持续更新的video1.mp4并无缝切换至最新版本？

• 核心目标：持续循环播放video1.mp4，当视频生成函数产出新的video1.mp4时，立即无缝切换到最新版本
• 过往尝试：先生成video2.mp4，检测到文件存在后重命名为video1.mp4，但未成功
• 当前实现缺陷：用OpenCV编写的video_player函数运行时，写入新video1.mp4会导致播放暂停，终端被错误信息刷屏，代码如下：

def video_player():
    cap = cv2.VideoCapture('video1.mp4')

    while  True:
        ret, frame = cap.read()
        if ret == True:
            cv2.imshow('Frame', frame)
            if cv2.waitKey(60) & 0xFF == ord('q'):
                break

        else:
            cap.release()
            cap = cv2.VideoCapture('video1.mp4')
            ret, frame = cap.read()

当前采用多进程同时运行视频生成函数与video_player函数，需实现无暂停、无缝切换至最新视频的方案。

方案1：修复文件重命名方案（利用原子性操作） #

之前重命名失败的核心原因是旧的video1.mp4被播放器进程占用，系统不允许直接覆盖。调整后步骤：

• 视频生成函数始终输出到临时文件（比如temp_video.mp4），生成完成后先删除旧的video1.mp4，再将临时文件重命名为video1.mp4（多数操作系统中，重命名是原子操作，只要旧文件被释放）
• 播放器端优化读取失败后的重试逻辑，增加短暂等待，确保文件替换完成后再重新打开

优化后的播放器代码：

import cv2
import time

def video_player():
    cap = None
    while True:
        # 尝试初始化视频捕获，失败则短暂等待后重试
        if cap is None or not cap.isOpened():
            try:
                cap = cv2.VideoCapture('video1.mp4')
            except:
                time.sleep(0.01)
                continue
        
        ret, frame = cap.read()
        if ret:
            cv2.imshow('Frame', frame)
            # 降低waitKey参数，提升响应速度
            if cv2.waitKey(1) & 0xFF == ord('q'):
                break
        else:
            # 读取失败，释放资源并标记需重新初始化
            cap.release()
            cap = None
            time.sleep(0.01)
    
    # 退出时清理资源
    if cap is not None:
        cap.release()
    cv2.destroyAllWindows()

视频生成函数示例：

import os
import time

def video_generator():
    while True:
        # 替换为你的视频生成逻辑，输出到临时文件
        generate_video_to('temp_video.mp4')
        
        # 原子替换旧视频文件
        if os.path.exists('video1.mp4'):
            os.remove('video1.mp4')
        os.rename('temp_video.mp4', 'video1.mp4')
        
        # 等待下一轮生成（替换为你的生成周期）
        time.sleep(5)

方案2：通过进程间通信传递帧（彻底规避文件IO冲突） #

绕开文件系统，直接让生成函数把帧通过多进程队列传递给播放器，从根源解决文件占用问题：

• 使用multiprocessing.Queue传递帧数据，队列设置最大长度避免内存溢出
• 生成函数每生成一帧就放入队列，播放器从队列取帧显示；生成新视频序列时，清空队列即可自动切换

完整代码示例：

import cv2
import multiprocessing
import time

def video_generator(frame_queue):
    while True:
        # 替换为你的视频生成逻辑，比如从摄像头采集或生成合成视频
        temp_cap = cv2.VideoCapture('your_source_video.mp4')
        while True:
            ret, frame = temp_cap.read()
            if not ret:
                break
            # 队列满时丢弃旧帧，保证播放最新内容
            if frame_queue.full():
                frame_queue.get()
            frame_queue.put(frame)
            # 控制生成帧率，和播放帧率匹配
            time.sleep(1/30)
        temp_cap.release()
        # 生成一轮后等待，或立即开始下一轮
        time.sleep(1)

def video_player(frame_queue):
    cv2.namedWindow('Frame', cv2.WINDOW_NORMAL)
    while True:
        if not frame_queue.empty():
            frame = frame_queue.get()
            cv2.imshow('Frame', frame)
        # 响应按键并控制播放帧率
        if cv2.waitKey(1) & 0xFF == ord('q'):
            break
    cv2.destroyAllWindows()

if __name__ == '__main__':
    # 设置队列最大长度，建议等于1-2倍帧率
    frame_queue = multiprocessing.Queue(maxsize=30)
    # 启动进程
    gen_process = multiprocessing.Process(target=video_generator, args=(frame_queue,))
    play_process = multiprocessing.Process(target=video_player, args=(frame_queue,))
    
    gen_process.start()
    play_process.start()
    
    play_process.join()
    gen_process.terminate()

方案3：监控文件修改时间，主动触发切换 #

播放器后台监控video1.mp4的修改时间，检测到文件更新时主动重新加载：

• 记录文件初始修改时间，定时检查是否变化
• 结合读取失败的重试逻辑，双重保障切换时机

代码示例：

import cv2
import os
import time

def video_player():
    cap = cv2.VideoCapture('video1.mp4')
    # 记录初始文件修改时间
    last_modified = os.path.getmtime('video1.mp4') if os.path.exists('video1.mp4') else 0
    
    while True:
        # 检查文件是否被更新
        if os.path.exists('video1.mp4'):
            current_modified = os.path.getmtime('video1.mp4')
            if current_modified != last_modified:
                cap.release()
                cap = cv2.VideoCapture('video1.mp4')
                last_modified = current_modified
        
        ret, frame = cap.read()
        if ret:
            cv2.imshow('Frame', frame)
            if cv2.waitKey(1) & 0xFF == ord('q'):
                break
        else:
            # 读取失败时重新加载
            cap.release()
            cap = cv2.VideoCapture('video1.mp4')
            if os.path.exists('video1.mp4'):
                last_modified = os.path.getmtime('video1.mp4')
            time.sleep(0.01)
    
    cap.release()
    cv2.destroyAllWindows()

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