#include <yarp/serversql/impl/ConnectThread.h>
Public Member Functions | |
ConnectThread (std::mutex &mutex) | |
void | run () override |
Main body of the new thread. More... | |
Public Member Functions inherited from yarp::os::Thread | |
Thread () | |
Constructor. More... | |
virtual | ~Thread () |
Destructor. More... | |
virtual void | onStop () |
Call-back, called while halting the thread (before join). More... | |
bool | start () |
Start the new thread running. More... | |
bool | stop () |
Stop the thread. More... | |
virtual void | beforeStart () |
Called just before a new thread starts. More... | |
virtual void | afterStart (bool success) |
Called just after a new thread starts (or fails to start), this is executed by the same thread that calls start(). More... | |
virtual bool | threadInit () |
Initialization method. More... | |
virtual void | threadRelease () |
Release method. More... | |
bool | isStopping () |
Returns true if the thread is stopping (Thread::stop has been called). More... | |
bool | isRunning () |
Returns true if the thread is running (Thread::start has been called successfully and the thread has not stopped). More... | |
long int | getKey () |
Get a unique identifier for the thread. More... | |
int | setPriority (int priority, int policy=-1) |
Set the priority and scheduling policy of the thread, if the OS supports that. More... | |
int | getPriority () |
Query the current priority of the thread, if the OS supports that. More... | |
int | getPolicy () |
Query the current scheduling policy of the thread, if the OS supports that. More... | |
bool | join (double seconds=-1) |
The function returns when the thread execution has completed. More... | |
void | setOptions (int stackSize=0) |
Set the stack size for the new thread. More... | |
Public Attributes | |
bool | needed {true} |
bool | positive {true} |
int | ct {0} |
std::mutex & | mutex |
std::string | src |
std::string | dest |
Additional Inherited Members | |
Static Public Member Functions inherited from yarp::os::Thread | |
static int | getCount () |
Check how many threads are running. More... | |
static long int | getKeyOfCaller () |
Get a unique identifier for the calling thread. More... | |
static void | yield () |
Reschedule the execution of current thread, allowing other threads to run. More... | |
static void | setDefaultStackSize (int stackSize) |
Set the default stack size for all threads created after this point. More... | |
Definition at line 21 of file ConnectThread.h.
ConnectThread::ConnectThread | ( | std::mutex & | mutex | ) |
Definition at line 22 of file ConnectThread.cpp.
|
overridevirtual |
Main body of the new thread.
Override this method to do what you want. After Thread::start is called, this method will start running in a separate thread. It is important that this method either keeps checking Thread::isStopping to see if it should stop, or you override the Thread::onStop method to interact with it in some way to shut the new thread down. There is no really reliable, portable way to stop a thread cleanly unless that thread cooperates.
Implements yarp::os::Thread.
Definition at line 26 of file ConnectThread.cpp.
int yarp::serversql::impl::ConnectThread::ct {0} |
Definition at line 26 of file ConnectThread.h.
std::string yarp::serversql::impl::ConnectThread::dest |
Definition at line 30 of file ConnectThread.h.
std::mutex& yarp::serversql::impl::ConnectThread::mutex |
Definition at line 27 of file ConnectThread.h.
bool yarp::serversql::impl::ConnectThread::needed {true} |
Definition at line 24 of file ConnectThread.h.
bool yarp::serversql::impl::ConnectThread::positive {true} |
Definition at line 25 of file ConnectThread.h.
std::string yarp::serversql::impl::ConnectThread::src |
Definition at line 29 of file ConnectThread.h.