减轻推理时负载，避免过载时造成系统死机

modules/inference/src/inference.cpp

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:35:37
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-10-13 09:54:15
+ * @LastEditTime: 2021-10-13 14:51:24
  */
 #include "inference.h"
 
@@ -54,7 +54,7 @@ GstElement *g_streammux = NULL;
 
 namespace MIVA{
     std::shared_ptr<Inference> infer = NULL;
-    // ThreadPool pool(3,ThreadPool::PRIORITY_HIGHEST, false);
+    ThreadPool pool(1,ThreadPool::PRIORITY_HIGHEST, false);
     /**
      * @description: 创建对象 单例
      * @param {*}
@@ -230,7 +230,11 @@ namespace MIVA{
             this->RestartTask();
         }else{
             ret++;
-            gst_element_set_state(this->pipeline, GST_STATE_PLAYING);
+            pool.async([&](){
+                gst_element_set_state(this->pipeline, GST_STATE_PLAYING);
+                g_main_loop_run(this->loop);
+            });
+            pool.start();
         }
     }
     /**
@@ -421,6 +425,16 @@ namespace MIVA{
             g_signal_connect (G_OBJECT (object), "child-added",
                 G_CALLBACK (decodebin_child_added), user_data);
         }
+        if (g_strrstr (name, "nvv4l2decoder") == name) {
+        #ifdef PLATFORM_TEGRA
+            g_object_set (object, "enable-max-performance", TRUE, NULL);
+            g_object_set (object, "bufapi-version", TRUE, NULL);
+            g_object_set (object, "drop-frame-interval", 0, NULL);
+            g_object_set (object, "num-extra-surfaces", 0, NULL);
+        #else
+            g_object_set (object, "gpu-id", 0, NULL);
+        #endif
+        }
     }
     /**
      * @description: 释放数据源
@@ -484,7 +498,7 @@ namespace MIVA{
             gchar pad_name[16] = { 0 };
             GstPad *sinkpad = NULL;
             g_snprintf (pad_name, 15, "sink_%u", source_id);
-
+            
             sinkpad = gst_element_get_static_pad (g_streammux, pad_name);
             if(sinkpad == NULL) sinkpad = gst_element_get_request_pad (g_streammux, pad_name);
             if (gst_pad_link (pad, sinkpad) != GST_PAD_LINK_OK) {

modules/userApp/src/user_app.cpp

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:35:42
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-10-13 09:47:30
+ * @LastEditTime: 2021-10-13 10:33:53
  */
 #include "user_app.h"
 
@@ -127,7 +127,7 @@ namespace MIVA
         }else{
             InfoL << "The stream to be played is not found, please add it in the background.";
         }
-
+        
         // 监听推理广播
         NoticeCenter::Instance().addListener(0,NOTICE_INFER,
                 [&](int Source_id, int num){
@@ -157,7 +157,6 @@ namespace MIVA
         InfoL << "System initialization is successful!";
         return OK;
     }
-
     /**
      * @description: 释放数据
      * @param {*}
@@ -179,7 +178,7 @@ namespace MIVA
     {
         // 挂起任务一
         poolInfer.async([&](){
-            if(this->m_Infer != NULL) m_Infer->ReadyTask();
+            if(this->m_Infer != NULL) m_Infer->StartTask();
         });
 
         // 挂起函数回调
@@ -200,7 +199,8 @@ namespace MIVA
             this->ReportData(); // 上报数据
             return true;
         }, nullptr);
-
+        // 记录时间
+        clock_gettime(CLOCK_BOOTTIME, &time1);
         poolInfer.start();
         InfoL << "Task started successfully!";
     }
@@ -438,6 +438,7 @@ namespace MIVA
             // 更新数据
             sqlUpdata << grade << result << ctime << iter->first << sqlRet;
         }
+  
         clock_gettime(CLOCK_BOOTTIME, &time2);
         WarnL << "推理所用时间： " << (time2.tv_sec - time1.tv_sec) *1000 + (time2.tv_nsec - time1.tv_nsec)/1000000 << " ms";
 

source/src/main.cpp

@@ -4,7 +4,7 @@
  * @Autor: lishengyin
  * @Date: 2021-10-13 09:35:48
  * @LastEditors: lishengyin
- * @LastEditTime: 2021-10-13 09:39:31
+ * @LastEditTime: 2021-10-13 15:05:32
  */
 #include <iostream>
 #include "user_app.h"
@@ -22,6 +22,7 @@ int main(int argc, char *argv[])
 
    //设置日志
   Logger::Instance().add(std::make_shared<ConsoleChannel>());
+  Logger::Instance().add(std::make_shared<FileChannel>());
   Logger::Instance().setWriter(std::make_shared<AsyncLogWriter>());
 
   gst_init(&argc, &argv);