This commit is contained in:
cxh 2025-10-15 10:05:31 +08:00
parent 04865dc3ba
commit 90ec397d97

View File

@ -58,11 +58,11 @@ private:
}; };
// RTMPManager 内部增加 // RTMPManager 内部增加
std::mutex stop_queue_mutex; static std::mutex stop_queue_mutex;
std::condition_variable stop_cv; static std::condition_variable stop_cv;
std::queue<std::unique_ptr<StreamContext>> stop_queue; static std::queue<std::unique_ptr<StreamContext>> stop_queue;
std::atomic<bool> stop_thread_running{false}; static std::atomic<bool> stop_thread_running{false};
std::thread stop_thread; static std::thread stop_thread;
// store unique_ptr to avoid copy/move issues with atomic/thread // store unique_ptr to avoid copy/move issues with atomic/thread
static std::unordered_map<std::string, std::unique_ptr<StreamContext>> streams; static std::unordered_map<std::string, std::unique_ptr<StreamContext>> streams;
static std::mutex streams_mutex; static std::mutex streams_mutex;