multithreading - 引用队列中的前数据包时程序终止

Question

我有 2 个线程来解码 RTSP 流视频，我的代码如下:

    int key = 0;
    std::queue<AVpacket> Packet_buf;

    int thread1 (void) 
    {
           AVPacket packet;
           packet = read_packet();
           Packet_buf.push(packet);
           av_packet_unref(&packet);
           key = 1;
    }

    int thread2 (void)
    {
          AVPacket *packet;
          while(key==0) {} // wait to read the first packet
          *packet = Packet_buf.front(); // program halt here
          avcodec_send_packet(pCodecCtx,packet);
    }

    int main();
    {
         thread p1(thread1);
         thread p2(thread2);
    }

我的程序在线崩溃:*packet = Packet_buf.front();

你能帮我找出问题吗，谢谢!

Answer 1

您的代码有更多的问题，其中一些:

1) std::queue<AVpacket> Packet_buf;
我认为这将是:
std::queue<AVPacket> Packet_buf;通知 AVpacket和 AVPacket是完全不同的事情。 (是的，我猜这只是一个错字)。

2) while(key==0) {}这不是等待变量更改的好方法。特别是如果变量(键)不是 volatile .它可能工作并且可能正在工作。但我建议你使用 pthread signal和 cond在这里替换变量。另请检查密切相关的下一个问题(3)。

3) *packet = Packet_buf.front();校准 std::queue.front()在检查容器是否为 empty() 之前或不是不是好主意。如果容器(队列)为空而不是 front()此处的方法将导致未定义的行为。

希望有帮助。