ToolDAQFramework
|
#include <MyToolZMQMultiThread.h>
Public Member Functions | |
MyToolZMQMultiThread () | |
Simple constructor. More... | |
bool | Execute () |
Executre function used to perform Tool perpose. More... | |
bool | Finalise () |
Finalise funciton used to clean up resorces. More... | |
bool | Initialise (std::string configfile, DataModel &data) |
Initialise Function for setting up Tool resorces. More... | |
Static Private Member Functions | |
static void | Thread (Thread_args *arg) |
Function to be run by the thread in a loop. Make sure not to block in it. More... | |
Private Attributes | |
std::vector < MyToolZMQMultiThread_args * > | args |
Vector of thread args (also holds pointers to the threads) More... | |
zmq::pollitem_t | items [2] |
This is used to both inform the poll and store its output. Allows for multitasking sockets. More... | |
int | m_freethreads |
Keeps track of free threads. More... | |
Utilities * | m_util |
Pointer to utilities class to help with threading. More... | |
zmq::socket_t * | ManagerReceive |
Socket to receive information form threads. More... | |
zmq::socket_t * | ManagerSend |
Socket to send information to threads. More... | |
This is a template for a Tool that provides multiple worker threads and comunicates with them via ZMQ in a thread safe way. Please fill out the descripton and author information.
Contact: b.ric hard s@qmu l.ac .uk
Definition at line 37 of file MyToolZMQMultiThread.h.
MyToolZMQMultiThread::MyToolZMQMultiThread | ( | ) |
Simple constructor.
Definition at line 8 of file MyToolZMQMultiThread.cpp.
bool MyToolZMQMultiThread::Execute | ( | ) |
Executre function used to perform Tool perpose.
Definition at line 56 of file MyToolZMQMultiThread.cpp.
bool MyToolZMQMultiThread::Finalise | ( | ) |
Finalise funciton used to clean up resorces.
Definition at line 91 of file MyToolZMQMultiThread.cpp.
bool MyToolZMQMultiThread::Initialise | ( | std::string | configfile, |
DataModel & | data | ||
) |
Initialise Function for setting up Tool resorces.
configfile | The path and name of the dynamic configuration file to read in. |
data | A reference to the transient data class used to pass information between Tools. |
Definition at line 11 of file MyToolZMQMultiThread.cpp.
|
staticprivate |
Function to be run by the thread in a loop. Make sure not to block in it.
Definition at line 109 of file MyToolZMQMultiThread.cpp.
|
private |
Vector of thread args (also holds pointers to the threads)
Definition at line 52 of file MyToolZMQMultiThread.h.
|
private |
This is used to both inform the poll and store its output. Allows for multitasking sockets.
Definition at line 54 of file MyToolZMQMultiThread.h.
|
private |
Keeps track of free threads.
Definition at line 58 of file MyToolZMQMultiThread.h.
|
private |
Pointer to utilities class to help with threading.
Definition at line 51 of file MyToolZMQMultiThread.h.
|
private |
Socket to receive information form threads.
Definition at line 56 of file MyToolZMQMultiThread.h.
|
private |
Socket to send information to threads.
Definition at line 55 of file MyToolZMQMultiThread.h.