big refacting of communitation architect

opencv-motion-detect/evmlmotion.cpp

@@ -715,7 +715,6 @@ int main(int argc, const char *argv[])
     av_log_set_level(AV_LOG_ERROR);
     queue<string> evtQueue;
     EvMLMotion es(&evtQueue);
-    es.detach();
 
 #ifdef DEBUG
     cv::namedWindow( "Display window", cv::WINDOW_AUTOSIZE );
@@ -732,17 +731,7 @@ int main(int argc, const char *argv[])
         }
     }
 #else
-    while(true) {
-        if(evtQueue.size() >  0) {
-            string p = evtQueue.front();
-            spdlog::info("evmlmotion event: {}", p);
-            evtQueue.pop();
-        }
-        else {
-            this_thread::sleep_for(chrono::duration(chrono::seconds(2)));
-        }
-    }
-
+    es.join();
 #endif
     return 0;
 }
\ No newline at end of file

opencv-motion-detect/evslicer.cpp

@@ -203,20 +203,6 @@ private:
             exit(1);
         }
 
-        thMsgProcessor = thread([this](){
-            while(true) {
-                auto body = z_recv_multiple(pDealer,false);
-                if(body.size() == 0) {
-                    spdlog::error("evslicer {} failed to receive multiple msg: {}", selfId, zmq_strerror(zmq_errno()));
-                    continue;
-                }
-                // full proto msg received.
-                handleMsg(body);
-            }
-        });
-
-        thMsgProcessor.detach();
-
         return ret;
     }
 
@@ -512,6 +498,21 @@ public:
         init();
         getInputFormat();
         setupStream();
+
+        // thread for msg
+        thMsgProcessor = thread([this](){
+            while(true) {
+                auto body = z_recv_multiple(pDealer,false);
+                if(body.size() == 0) {
+                    spdlog::error("evslicer {} failed to receive multiple msg: {}", selfId, zmq_strerror(zmq_errno()));
+                    continue;
+                }
+                // full proto msg received.
+                handleMsg(body);
+            }
+        });
+
+        thMsgProcessor.detach();
     };
     ~EvSlicer()
     {