From d9a1d9732f4fc456f287736aef9e69c9435ac418 Mon Sep 17 00:00:00 2001 From: cxh Date: Wed, 10 Sep 2025 12:54:39 +0800 Subject: [PATCH] first commit --- src/main.cpp | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/main.cpp b/src/main.cpp index 48c44b9..90d5fd8 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -52,15 +52,18 @@ int main() // 先在主线程初始化 GStreamer RTSPManager::init(); + std::thread rtsp_thread = nullptr; + std::thread mqtt_thread = nullptr; + std::thread rtsp_thread([&]() { RTSPManager::start(g_app_config.cameras); rtsp_thread_exited.store(true, std::memory_order_relaxed); }); - // std::thread mqtt_thread([&]() - // { - // mqtt_client_thread_func(); - // mqtt_thread_exited.store(true, std::memory_order_relaxed); }); + std::thread mqtt_thread([&]() + { + mqtt_client_thread_func(); + mqtt_thread_exited.store(true, std::memory_order_relaxed); }); // 等待退出信号 while (g_running.load(std::memory_order_relaxed))