|
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.richards@qmul.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.
1.8.5