stream_worker.hpp

//
// Created by pengx on 2026/2/10.
//

#ifndef GB28181_STREAM_WORKER_HPP
#define GB28181_STREAM_WORKER_HPP

#pragma once
#include <QMutex>
#include <QTimer>
#include <vector>

struct VideoFrame {
    std::vector<uint8_t> data;
    uint32_t pts;
};

class StreamWorker : public QObject {
    Q_OBJECT

public:
    explicit StreamWorker(size_t bufferSize = 30, QObject* parent = nullptr);
    ~StreamWorker() override;

public slots:
    // 生产者：快速写入
    void frameReceived(const std::vector<uint8_t>& h264Data, uint32_t pts);

    // 消费者：处理帧
    void handleFrame();

private:
    struct FrameBuffer {
        std::vector<VideoFrame> frames;
        size_t writeIndex = 0;
        size_t readIndex = 0;
        size_t count = 0;
        size_t capacity = 0;
    } _ringBuffer;

    QMutex _mutex;
    bool _isProcessing = false;
};


#endif //GB28181_STREAM_WORKER_HPP