Changeset 293 in pacpusframework for trunk/examples/ProducerConsumerExample

Timestamp:

Mar 27, 2014, 3:50:21 PM (11 years ago)

Author:

Marek Kurdej

Message:

REVERTED: Reworked threading in InputInterfaceBase, each slot has its own processing thread.

Location:

trunk/examples/ProducerConsumerExample

Files:

• ConsumerExample.cpp (modified) (2 diffs)
• ConsumerExample.h (modified) (2 diffs)
• ProducerExample.cpp (modified) (2 diffs)

trunk/examples/ProducerConsumerExample/ConsumerExample.cpp

@@ -60 +60 @@
     setState(MONITOR_OK);
     LOG_INFO("started component '" << getName() << "'");
+
+    moveToThread(&mThread);
+    mThread.start();
 }
 
@@ -69 +72 @@
     setState(STOPPED);
     LOG_INFO("stopped component '" << getName() << "'");
+    QMetaObject::invokeMethod(&mThread, "quit");
 }
 

trunk/examples/ProducerConsumerExample/ConsumerExample.h

@@ -7 +7 @@
 #include <Pacpus/kernel/ComponentBase.h>
 #include <QImage>
+#include <QThread>
 #include <string>
 
@@ -37 +38 @@
 
     std::string mOutputFileName;
+    QThread mThread;
 };
 

trunk/examples/ProducerConsumerExample/ProducerExample.cpp

@@ -15 +15 @@
 
 PACPUS_REGISTER_COMPONENT(ProducerExample);
-
-static const char * outputFileName = "producer.txt";
 
 ProducerExample::ProducerExample(QString name)
@@ -62 +60 @@
     using boost::ref;
 
-    std::fstream mFile(outputFileName, std::ios_base::out | std::ios_base::app);
+    std::fstream mFile(mOutputFileName, std::ios_base::out | std::ios_base::app);
     if (!mFile.is_open()) {
-        LOG_ERROR("file '" << outputFileName << "' cannot be opened");
+        LOG_ERROR("file '" << mOutputFileName << "' cannot be opened");
         return;
     }