A class which provides a relatively platform-independent thread primitive. More...
#include <system-thread.h>
Public Types | |
typedef pthread_t | ThreadId |
Public Member Functions | |
SystemThread (Callback< void > callback) | |
Create a SystemThread object. More... | |
~SystemThread () | |
Destroy a SystemThread object. More... | |
void | Join (void) |
Suspend the caller until the thread of execution, running the provided callback, finishes. More... | |
void | Start (void) |
Start a thread of execution, running the provided callback. More... | |
![]() | |
SimpleRefCount () | |
Constructor. More... | |
SimpleRefCount (const SimpleRefCount &o) | |
Copy constructor. More... | |
uint32_t | GetReferenceCount (void) const |
Get the reference count of the object. More... | |
SimpleRefCount & | operator= (const SimpleRefCount &o) |
Assignment. More... | |
void | Ref (void) const |
Increment the reference count. More... | |
void | Unref (void) const |
Decrement the reference count. More... | |
Static Public Member Functions | |
static bool | Equals (ThreadId id) |
Compares an TharedId with the current ThreadId . More... | |
static ThreadId | Self (void) |
Returns the current thread Id. More... | |
![]() | |
static void | Cleanup (void) |
Noop. More... | |
Static Private Member Functions | |
static void * | DoRun (void *arg) |
Private Attributes | |
Callback< void > | m_callback |
pthread_t | m_thread |
A class which provides a relatively platform-independent thread primitive.
This class allows for creation of multiple threads of execution in a process. The exact implementation of the thread functionality is operating system dependent, but typically in ns-3 one is using an environment in which Posix Threads are supported (either navively or in the case of Windows via Cygwin's implementation of pthreads on the Win32 API. In either case we expect that these will be kernel-level threads and therefore a system with multiple CPUs will see truly concurrent execution.
Synchronization between threads is provided via the SystemMutex class.
Definition at line 47 of file system-thread.h.
typedef pthread_t ns3::SystemThread::ThreadId |
Definition at line 52 of file system-thread.h.
ns3::SystemThread::SystemThread | ( | Callback< void > | callback | ) |
Create a SystemThread object.
A system thread object is not created running. A thread of execution must be explicitly started by calling the Start method. When the Start method is called, it will spawn a thread of execution and cause that thread to call out into the callback function provided here as a parameter.
Like all ns-3 callbacks, the provided callback may refer to a function or a method of an object depending on how the MakeCallback function is used.
The most common use is expected to be creating a thread of execution in a method. In this case you would use code similar to,
MyClass myObject; Ptr<SystemThread> st = Create<SystemThread> ( MakeCallback (&MyClass::MyMethod, &myObject)); st->Start ();
The SystemThread is passed a callback that calls out to the function MyClass::MyMethod. When this function is called, it is called as an object method on the myObject object. Essentially what you are doing is asking the SystemThread to call object->MyMethod () in a new thread of execution.
If starting a thread in your currently executing object, you can use the "this" pointer:
Ptr<SystemThread> st = Create<SystemThread> ( MakeCallback (&MyClass::MyMethod, this)); st->Start ();
Object lifetime is always an issue with threads, so it is common to use smart pointers. If you are spinning up a thread in an object that is managed by a smart pointer, you can use that pointer directly:
Ptr<MyClass> myPtr = Create<MyClass> (); Ptr<SystemThread> st = Create<SystemThread> ( MakeCallback (&MyClass::MyMethod, myPtr)); st->Start ();
Just like any thread, you can synchronize with its termination. The method provided to do this is Join (). If you call Join() you will block until the SystemThread run method returns.
callback | entry point of the thread |
Definition at line 32 of file system-thread.cc.
References NS_LOG_FUNCTION.
ns3::SystemThread::~SystemThread | ( | ) |
Destroy a SystemThread object.
Definition at line 38 of file system-thread.cc.
References NS_LOG_FUNCTION.
|
staticprivate |
Definition at line 73 of file system-thread.cc.
References m_callback, and NS_LOG_FUNCTION.
Referenced by Start().
|
static |
Compares an TharedId with the current ThreadId .
Definition at line 90 of file system-thread.cc.
References NS_LOG_FUNCTION.
Referenced by ns3::DefaultSimulatorImpl::Schedule(), ns3::DefaultSimulatorImpl::ScheduleDestroy(), ns3::DefaultSimulatorImpl::ScheduleNow(), ns3::DefaultSimulatorImpl::ScheduleWithContext(), and ns3::RealtimeSimulatorImpl::ScheduleWithContext().
void ns3::SystemThread::Join | ( | void | ) |
Suspend the caller until the thread of execution, running the provided callback, finishes.
Definition at line 59 of file system-thread.cc.
References m_thread, NS_FATAL_ERROR, and NS_LOG_FUNCTION.
Referenced by test().
|
static |
Returns the current thread Id.
Definition at line 83 of file system-thread.cc.
References NS_LOG_FUNCTION_NOARGS.
Referenced by ns3::DefaultSimulatorImpl::DefaultSimulatorImpl(), ns3::RealtimeSimulatorImpl::RealtimeSimulatorImpl(), ns3::DefaultSimulatorImpl::Run(), and ns3::RealtimeSimulatorImpl::Run().
void ns3::SystemThread::Start | ( | void | ) |
Start a thread of execution, running the provided callback.
Definition at line 44 of file system-thread.cc.
References DoRun(), m_thread, NS_FATAL_ERROR, and NS_LOG_FUNCTION.
Referenced by test().
|
private |
Definition at line 149 of file system-thread.h.
Referenced by DoRun().
|
private |
Definition at line 150 of file system-thread.h.