#include <yarp/serversql/impl/ConnectThread.h>
Inheritance diagram for yarp::serversql::impl::ConnectThread: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.