如何正确终止运行GStreamer管道的Python多进程？

你的进程无法正常join主要有三个核心问题，下面逐一说明并给出修复方案：

1. 队列清空逻辑完全写反了 #

你在stop方法里的队列清空循环是：

while not not self.full_frame_queue.empty():
    self.full_frame_queue.get()

双重否定后等价于while self.full_frame_queue.empty()——这意味着只有当队列为空时才会进入循环，不仅清不了队列，还可能直接卡死在这里，根本执行不到后面的join步骤。

正确写法应该是当队列不为空时持续取出元素，保险起见还可以给get加超时避免阻塞：

while not self.full_frame_queue.empty():
    try:
        self.full_frame_queue.get(timeout=1)
    except queue.Empty:
        break

2. pull-sample阻塞导致循环无法退出 #

full_sink.emit("pull-sample")是阻塞调用，当你在主线程清空running标志后，子进程可能还卡在这个调用上，根本没法检查running状态，自然退不出循环，也执行不了finally里的管道清理。

最直接的解决办法是给pull-sample加超时，让它定期返回，这样循环就能检查running标志：

while self.running.is_set():
    # 设置100ms超时，到点自动返回，无需额外sleep
    full_sample = full_sink.emit("pull-sample", Gst.CLOCK_TIME_NONE, 100 * Gst.MSECOND)
    if full_sample:
        self.process_frame(full_sample)

注意：这个超时参数需要GStreamer 1.16及以上版本支持。如果你的版本较低，可以改用appsink的new-sample信号回调，结合GObject主循环处理，避免阻塞。同时要确保sink配置正确：

full_sink = pipeline.get_by_name("full_sink")
full_sink.set_property("emit-signals", True)
full_sink.set_property("sync", False)

3. 管道状态切换未等待完成 #

你在finally块里调用pipeline.set_state(Gst.State.NULL)后直接打印日志，但GStreamer的状态切换是异步的，可能还没完成就退出了，导致资源残留，影响进程终止。

可以通过get_state等待状态切换完成：

finally:
    Gst.Element.send_event(pipeline, Gst.Event.new_eos())
    print("EoS sent")
    # 等待状态切换，超时5秒
    ret, _, _ = pipeline.set_state(Gst.State.NULL)
    if ret == Gst.StateChangeReturn.SUCCESS:
        print("Switched to NULL state")
    else:
        print("Failed to switch pipeline to NULL state")

兜底方案：强制终止（必要时可用） #

如果修改后进程还是无法join，可以在join超时后强制杀死进程：

self.capture_process.join(timeout=10)
if self.capture_process.is_alive():
    print("Capture process stuck, forcing kill")
    self.capture_process.kill()

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