#include <thread.h>
Inheritance diagram for PThread:
Construction | |
enum | Priority { LowestPriority, LowPriority, NormalPriority, HighPriority, HighestPriority, NumPriorities } |
Codes for thread priorities. More... | |
enum | AutoDeleteFlag { AutoDeleteThread, NoAutoDeleteThread } |
Codes for thread autodelete flag. More... | |
PThread (PINDEX, AutoDeleteFlag deletion=AutoDeleteThread, Priority priorityLevel=NormalPriority, const PString &threadName=PString::Empty()) | |
~PThread () | |
Control functions | |
virtual void | Restart () |
virtual void | Terminate () |
virtual BOOL | IsTerminated () const |
void | WaitForTermination () const |
BOOL | WaitForTermination (const PTimeInterval &maxWait) const |
virtual void | Suspend (BOOL susp=TRUE) |
virtual void | Resume () |
virtual BOOL | IsSuspended () const |
virtual void | SetPriority (Priority priorityLevel) |
virtual Priority | GetPriority () const |
virtual void | SetAutoDelete (AutoDeleteFlag deletion=AutoDeleteThread) |
void | SetNoAutoDelete () |
virtual PString | GetThreadName () const |
virtual void | SetThreadName (const PString &name) |
static void | Sleep (const PTimeInterval &delay) |
Suspend the current thread for the specified amount of time. | |
Miscellaneous | |
virtual PThreadIdentifier | GetThreadId () const |
virtual void | Main ()=0 |
static PThreadIdentifier | GetCurrentThreadId () |
static PThread * | Current () |
static void | Yield () |
static PThread * | Create (const PNotifier ¬ifier, INT parameter=0, AutoDeleteFlag deletion=AutoDeleteThread, Priority priorityLevel=NormalPriority, const PString &threadName=PString::Empty(), PINDEX stackSize=10000) |
Public Member Functions | |
int | PXBlockOnChildTerminate (int pid, const PTimeInterval &timeout) |
int | PXBlockOnIO (int handle, int type, const PTimeInterval &timeout) |
void | PXAbortBlock () const |
Overrides from PObject | |
void | PrintOn (ostream &strm) const |
Protected Member Functions | |
void | InitialiseProcessThread () |
Friends | |
class | PProcess |
class | PTrace::Block |
The implementation of a thread is platform dependent, but it is assumed that the platform has some support for native threads. Previous versions of PWLib has some support for co-operative threads, but this has been removed
|
Codes for thread autodelete flag.
|
|
|
Create a new thread instance. Unless the startSuspended# parameter is TRUE, the threads Main()# function is called to execute the code for the thread. Note that the exact timing of the execution of code in threads can never be predicted. Thus you you can get a race condition on intialising a descendent class. To avoid this problem a thread is always started suspended. You must call the Resume() function after your descendent class construction is complete. If synchronisation is required between threads then the use of semaphores is essential. If the deletion# is set to AutoDeleteThread# then the PThread is assumed to be allocated with the new operator and may be freed using the delete operator as soon as the thread is terminated or executes to completion (usually the latter). The stack size argument retained only for source code compatibility for previous implementations. It is not used in the current code and may be removed in subsequent versions.
|
|
Destroy the thread, this simply calls the Terminate()# function with all its restrictions and penalties. See that function for more information. Note that the correct way for a thread to terminate is to return from the Main()# function. |
|
Create a simple thread executing the specified notifier. This creates a simple PThread class that automatically executes the function defined by the PNotifier in the context of a new thread.
|
|
Get the currently running thread object instance. It is possible, even likely, that the smae code may be executed in the context of differenct threads. Under some circumstances it may be necessary to know what the current codes thread is and this static function provides that information.
Reimplemented in PProcess, PServiceProcess, and PHTTPServiceProcess. |
|
Get operating system specific thread identifier for current thread. |
|
Get the current priority of the thread in the current process.
|
|
Get operating system specific thread identifier for this thread. |
|
Get the name of the thread. Thread names are a optional debugging aid.
Reimplemented in PProcess. |
|
|
|
Determine if the thread is currently suspended. This checks the suspension count and if greater than zero returns TRUE for a suspended thread.
|
|
Determine if the thread has been terminated or ran to completion.
|
|
User override function for the main execution routine of the thread. A descendent class must provide the code that will be executed in the thread within this function. Note that the correct way for a thread to terminate is to return from this function. Implemented in PHTTPServiceThread. |
|
Standard stream print function. The PObject class has a << operator defined that calls this function polymorphically.
Reimplemented from PObject. |
|
|
|
|
|
|
|
Restart a terminated thread using the same stack priority etc that was current when the thread terminated. If the thread is still running then this function is ignored. |
|
Resume thread execution, this is identical to Suspend(FALSE)#. |
|
Set the flag indicating thread object is to be automatically deleted when the thread ends.
|
|
Reet the flag indicating thread object is to be automatically deleted when the thread ends. |
|
Set the priority of the thread relative to other threads in the current process.
|
|
Change the name of the thread. Thread names are a optional debugging aid.
Reimplemented in PProcess. |
|
Suspend the current thread for the specified amount of time.
|
|
Suspend or resume the thread. If susp# is TRUE this increments an internal count of suspensions that must be matched by an equal number of calls to Resume()# or Suspend(FALSE)# before the thread actually executes again. If susp# is FALSE then this decrements the internal count of suspensions. If the count is <= 0 then the thread will run. Note that the thread will not be suspended until an equal number of Suspend(TRUE)# calls are made.
|
|
Terminate the thread. It is highly recommended that this is not used except in abnormal abort situations as not all clean up of resources allocated to the thread will be executed. This is especially true in C++ as the destructors of objects that are automatic variables are not called causing at the very least the possiblity of memory leaks. Note that the correct way for a thread to terminate is to return from the Main()# function or self terminate by calling Terminate()# within the context of the thread which can then assure that all resources are cleaned up. Reimplemented in PProcess, and PServiceProcess. |
|
|
|
Block and wait for the thread to terminate.
|
|
Yield to another thread without blocking. This duplicates the implicit thread yield that may occur on some I/O operations or system calls. This may not be implemented on all platforms. |
|
|
|
|