Changeset 291 in pacpusframework for trunk/examples/ProducerConsumerExample/ProducerExample.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/ProducerExample.cpp (modified) (4 diffs)

trunk/examples/ProducerConsumerExample/ProducerExample.cpp

@@ -1 +1 @@
 #include "ProducerExample.h"
 
-#include <fstream>
 #include <Pacpus/kernel/ComponentFactory.h>
 #include <Pacpus/kernel/ComponentManager.h>
 #include <Pacpus/kernel/InputOutputInterface.h>
 #include <Pacpus/kernel/Log.h>
+
+#include <boost/bind.hpp>
+#include <boost/thread.hpp>
 
 using namespace pacpus;
@@ -18 +20 @@
 ProducerExample::ProducerExample(QString name)
     : ComponentBase(name)
+    , mInterval(boost::posix_time::milliseconds(150))
+    , mTimer(mIo, mInterval)
 {
-    LOG_TRACE("constructor(" << name << ")");
+    PACPUS_LOG_FUNCTION();
 
     namespace po = boost::program_options;
@@ -30 +34 @@
 ProducerExample::~ProducerExample()
 {
-    LOG_TRACE("destructor");
+    PACPUS_LOG_FUNCTION();
 }
 
-ComponentBase::COMPONENT_CONFIGURATION
-ProducerExample::configureComponent(XmlComponentConfig /*config*/)
+ComponentBase::COMPONENT_CONFIGURATION ProducerExample::configureComponent(XmlComponentConfig /*config*/)
 {
     PACPUS_LOG_FUNCTION();
@@ -54 +57 @@
 void ProducerExample::startActivity()
 {
-    LOG_TRACE(Q_FUNC_INFO);
+    PACPUS_LOG_FUNCTION();
 
-    start();
+    using boost::bind;
+    using boost::ref;
+
+    std::fstream mFile(outputFileName, std::ios_base::out | std::ios_base::app);
+    if (!mFile.is_open()) {
+        LOG_ERROR("file '" << outputFileName << "' cannot be opened");
+        return;
+    }
+
+    mImageOutput = getTypedOutput<QImage, ProducerExample>("image");
+
     setActive(true);
     setState(MONITOR_OK);
     LOG_INFO("started component '" << getName() << "'");
+
+    int counter = 0;
+    mTimer.async_wait(bind(&ProducerExample::produce, this, ref(counter)));
+    boost::thread t(bind(&boost::asio::io_service::run, ref(mIo)));
+    //mIo.run();
 }
 
 void ProducerExample::stopActivity()
 {
-    LOG_TRACE(Q_FUNC_INFO);
+    PACPUS_LOG_FUNCTION();
 
     setActive(false);
     setState(STOPPED);
     LOG_INFO("stopped component '" << getName() << "'");
+    
+    mFile.close();
 }
 
-void ProducerExample::run()
+void ProducerExample::produce(int& counter)
 {
-    unsigned int counter = 1;
-    int waitTimeMicros = 150 * 1000;
+    if (!isActive()) {
+        return;
+    }
+    
+    QImage mat(10, 10, QImage::Format_RGB32);
+    //mat.fill( qRgb(189, 149, 39));
+    //mat.setPixel(0,0,i);
+    LOG_INFO("Sending QImage: "
+        << "size = " << mat.size().width()<< " x " << mat.size().height()
+        );
 
-    std::fstream file(outputFileName, std::ios_base::out | std::ios_base::app);
-    if (!file.is_open()) {
-        LOG_ERROR("file '" << outputFileName << "' cannot be opened");
-    }
-
-    QImage mat(10000, 1000, QImage::Format_RGB32);
-    //mat.fill( qRgb(189, 149, 39));
-
-    OutputInterface<QImage, ProducerExample> * imageOutput = 
-        getTypedOutput<QImage, ProducerExample>("image");
-
-    while (isActive()) {
-        //mat.setPixel(0,0,i);
-        LOG_INFO("Sent QImage: "
-            << "size = " << mat.size().width()<< " x " << mat.size().height()
-            );
-
-        checkedSend(imageOutput, mat);
-
-        LOG_INFO("Sent data=" << counter << ", time=" << road_time());
-        file << counter << " " << road_time() << "\n" << std::flush;
-
-        usleep(waitTimeMicros);
-        ++counter;
-        setState(MONITOR_OK);
-    }
-
-    file.close();
+    checkedSend(mImageOutput, mat);
+    LOG_INFO("Sent data=" << counter << ", time=" << road_time());
+    mFile << counter << " " << road_time() << "\n" << std::flush;
+    ++counter;
+    setState(MONITOR_OK);
+    
+    using boost::bind;
+    using boost::ref;
+    mTimer.expires_at(mTimer.expires_at() + mInterval);
+    mTimer.async_wait(bind(&ProducerExample::produce, this, ref(counter)));
 }