Gstreamer Python pipeline发送EOS后无法正常停止问题求助

• 线程上下文问题：你通过Gst.Clock.id_wait_async()注册的end_recording回调运行在GStreamer独立的时钟线程中，虽然send_event本身线程安全，但部分硬件编码器（如你用到的omxh264enc）对跨线程事件的响应存在延迟，可能导致EOS没有向下游所有分支正确传递。
• 队列配置错误：音频分支的queue设置了三个上限全为0，意味着队列无上限缓存数据，EOS事件需要等队列内所有数据全部处理完成才会向下传递，如果此时音视频时间戳不匹配，qtmux会一直等待匹配的帧完成封装，永远不会向下游传递EOS，总线收不到EOS消息就不会触发主循环退出。
• 计时时机错误：你在pipeline还未切换到PLAYING状态时就获取时钟时间计算停止点，此时pipeline时钟未完成同步，可能出现pipeline还未开始采集就触发EOS，qtmux会等待永远不会到达的首帧数据，直接卡住。
• 硬件编码器缓存问题：omxh264enc硬件编码器默认会缓存多帧数据才输出，EOS触发后编码器内的缓存帧如果没有完全输出，也会导致整条分支卡住。

• 替换计时逻辑：删除原有的时钟异步等待逻辑，在pipeline切换到PLAYING状态后，用GLib主循环的定时器触发EOS，确保事件在主循环线程发送：

  # 删掉原有的clock相关代码，在pipeline.set_state(Gst.State.PLAYING)之后添加
  GLib.timeout_add_seconds(record_time_seconds, end_recording, pipeline)
  

• 修正队列配置：给音频、视频分支都加上有合理上限的queue，避免无限缓存：
  管道调整为：

  v4l2src ! videorate ! video/x-raw, height={frame_height}, width={frame_width}, framerate={fps}/1 ! nvvidconv ! omxh264enc insert-sps-pps=true ! queue ! mux.
  pulsesrc device={audio_device} ! audio/x-raw, rate=44100, channels=2, width=32, depth=32 ! queue max-size-buffers=200 max-size-time=1000000000 max-size-bytes=10485760 ! lamemp3enc bitrate=256 ! mux.
  qtmux name=mux ! filesink location={output_path}
  

• 添加兜底逻辑：在发送EOS之后额外加一个5秒的兜底超时，如果超时还未收到总线EOS消息，直接强制退出主循环，避免永久卡住：

  def end_recording(pipeline):
      logger.info('Timer fired, sending EOS...')
      pipeline.send_event(Gst.Event.new_eos())
      # 加兜底超时
      GLib.timeout_add_seconds(5, lambda loop: loop.quit() if loop.is_running() else False, loop)
      return False
  

• 调整编码器配置：给omxh264enc添加insert-sps-pps=true参数，避免编码器缓存关键帧不输出。

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