Changeset 291 in pacpusframework for trunk/examples/ProducerConsumerExample/ProducerExample.h

Timestamp:

03/27/14 12:53:43 (10 years ago)

Author:

Marek Kurdej

Message:

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

File:

• trunk/examples/ProducerConsumerExample/ProducerExample.h (modified) (2 diffs)

trunk/examples/ProducerConsumerExample/ProducerExample.h

@@ -16 +16 @@
 #include <Pacpus/kernel/road_time.h>
 //#include <Pacpus/structure/genericStructures.h>
-#include <QThread>
+
+#include <boost/asio.hpp>
+#include <boost/date_time/posix_time/posix_time_types.hpp>
+#include <fstream>
 #include <QImage>
 
-namespace pacpus {                                                                              
+namespace pacpus
+{
 
 class PRODUCERCONSUMEREXAMPLE_API ProducerExample
-        : public QThread
-        , public ComponentBase
+    : public QObject
+    , public ComponentBase
 {
     Q_OBJECT
@@ -41 +45 @@
     virtual COMPONENT_CONFIGURATION configureComponent(XmlComponentConfig config);
 
-protected:
-    void run();
-
-public Q_SLOTS:
+private:
+    void produce(int& counter);
 
 private:
     std::string mOutputFileName;
-    //QThread thread;
+
+    std::fstream mFile;
+    OutputInterface<QImage, ProducerExample>* mImageOutput;
+
+    boost::asio::io_service mIo;
+    boost::posix_time::time_duration mInterval;
+    boost::asio::deadline_timer mTimer;
 };