Changeset 287 in pacpusframework

Timestamp:

Mar 26, 2014, 8:59:09 PM (11 years ago)

Author:

Marek Kurdej

Message:

MAJOR: InputOutputInterface has a separate thread for each input slot.

File:

• trunk/include/Pacpus/kernel/InputOutputInterface.h (modified) (7 diffs)

trunk/include/Pacpus/kernel/InputOutputInterface.h

@@ -8 +8 @@
 #include <QByteArray>
 #include <QCoreApplication>
+#include <QThread>
 #include <typeinfo>
 
-namespace pacpus {
+namespace pacpus
+{
 
 template <typename T, class C>
@@ -28 +30 @@
     //typedef boost::function<void (C*, T const&)> process_const_data_function_type;
 
+    void initialize()
+    {
+        // each input slot will be processed by a separate thread
+        moveToThread(&mProcessingThread);
+        mProcessingThread.start();
+    }
+
     InputInterface(QString name, C* component, process_data_function_type_with_event processingMethod)
         : InputInterfaceBase(name, component, component)
     {
         mProcessingMethod.fe = processingMethod;
+        initialize();
     }
     
@@ -38 +48 @@
     {
         mProcessingMethod.f = processingMethod;
+        initialize();
     }
     
@@ -44 +55 @@
     {
         mProcessingMethod.cfe = processingMethod;
+        initialize();
     }
     
@@ -50 +62 @@
     {
         mProcessingMethod.cf = processingMethod;
+        initialize();
     }
 
@@ -202 +215 @@
 
     ProcessingMethod mProcessingMethod;
+    QThread mProcessingThread;
 };
 
@@ -249 +263 @@
             it->getPriority()
         );
-        LOG_TRACE("Sender: " << it->getInterface()->getSignature());
+        LOG_TRACE("Sender: " << getSignature());
     }
 }