Changeset 291 in pacpusframework for trunk/examples/ProducerConsumerExample/ConsumerExample.cpp

Timestamp:

Mar 27, 2014, 12:53:43 PM (11 years ago)

Author:

Marek Kurdej

Message:

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

File:

• trunk/examples/ProducerConsumerExample/ConsumerExample.cpp (modified) (5 diffs)

trunk/examples/ProducerConsumerExample/ConsumerExample.cpp

@@ -17 +17 @@
     LOG_TRACE("constructor(" << name << ")");
 
-    LOG_INFO("Thread " << thread.currentThread());
-    LOG_INFO("Current Thread " << QThread::currentThread());
-
-    namespace po = boost::program_options;
     addParameters()
-        ("output-path", po::value<std::string>(&mOutputFileName)->default_value("consumer.txt"), "set output file path")
+        ("output-path", value<std::string>(&mOutputFileName)->default_value("consumer.txt"), "set output file path")
     ;
 }
@@ -55 +51 @@
 {
     LOG_TRACE(Q_FUNC_INFO);
-    moveToThread(&thread);
     m_counter = 0;
     
@@ -63 +58 @@
     }
 
-    thread.start();
     setState(MONITOR_OK);
     LOG_INFO("started component '" << getName() << "'");
@@ -72 +66 @@
     LOG_TRACE(Q_FUNC_INFO);
 
-    QMetaObject::invokeMethod(&thread, "quit");
     m_file.close();
     setState(STOPPED);
@@ -97 +90 @@
     
     PacpusTypedEvent<int> intEvent(TYPED_EVENT, 2);
-    //PacpusTypedEvent<QImage> imageEvent = intEvent;
+    //PacpusTypedEvent<QImage> imageEvent = intEvent; // should not compile
 }