class DerivedThread : Thread
 {
     this()
     {
         super( &run );
     }

 private :
     void run()
     {
         printf( "Derived thread running.\n" );
     }
 }

 void threadFunc()
 {
     printf( "Composed thread running.\n" );
 }

 // create instances of each type
 Thread derived = new DerivedThread();
 Thread composed = new Thread( &threadFunc );

 // start both threads
 derived.start();
 composed.start();

this(void(* fn)(), size_t sz = 0);

Initializes a thread object which is associated with a static D function.

Params:

void(* fn)()	The thread function.
uint sz	The stack size for this thread.

In:
fn must not be null.

this(void delegate() dg, size_t sz = 0);

Initializes a thread object which is associated with a dynamic D function.

Params:

void delegate() dg	The thread function.
uint sz	The stack size for this thread.

In:
dg must not be null.

final void start ();

Starts the thread and invokes the function or delegate passed upon construction.

In:
This routine may only be called once per thread instance.

Throws:
ThreadException if the thread fails to start .

final void join (bool rethrow = true);

Waits for this thread to complete. If the thread terminated as the result of an unhandled exception, this exception will be rethrown.

Params:

bool rethrow

Rethrow any unhandled exception which may have caused this thread to terminate.

Throws:
ThreadException if the operation fails. Any exception not handled by the joined thread.

final char[] name ();

Gets the user-readable label for this thread.

Returns:
The name of this thread.

final void name (char[] val);

Sets the user-readable label for this thread.

Params:

char[] val

The new name of this thread.

final bool isDaemon ();

Gets the daemon status for this thread.

Returns:
true if this is a daemon thread.

final void isDaemon (bool val);

Sets the daemon status for this thread.

Params:

bool val

The new daemon status for this thread.

final bool isRunning ();

Tests whether this thread is running.

Returns:
true if the thread is running, false if not.

static int PRIORITY_MIN ;

The minimum scheduling priority that may be set for a thread. On systems where multiple scheduling policies are defined, this value represents the minimum valid priority for the scheduling policy of the process.

static int PRIORITY_MAX ;

The maximum scheduling priority that may be set for a thread. On systems where multiple scheduling policies are defined, this value represents the minimum valid priority for the scheduling policy of the process.

final int priority ();

Gets the scheduling priority for the associated thread.

Returns:
The scheduling priority of this thread.

final void priority (int val);

Sets the scheduling priority for the associated thread.

Params:

int val

The new scheduling priority of this thread.

static void sleep (double period);

Suspends the calling thread for at least the supplied time, up to a maximum of (uint.max - 1) milliseconds.

Params:

double period

The minimum duration the calling thread should be suspended, in seconds. Sub-second durations are specified as fractional values.

In:
period must be less than (uint.max - 1) milliseconds.

Example:

 Thread.sleep( 0.05 ); // sleep for 50 milliseconds
 Thread.sleep( 5 );    // sleep for 5 seconds

static void yield ();

Forces a context switch to occur away from the calling thread.

static Thread getThis ();

Provides a reference to the calling thread.

Returns:
The thread object representing the calling thread. The result of deleting this object is undefined.

static Thread[] getAll ();

Provides a list of all threads currently being tracked by the system.

Returns:
An array containing references to all threads currently being tracked by the system. The result of deleting any contained objects is undefined.

static int opApply (int delegate(ref Thread) dg);

Operates on all threads currently being tracked by the system. The result of deleting any Thread object is undefined.

Params:

int delegate(ref Thread) dg

The supplied code as a delegate.

Returns:
Zero if all elemented are visited, nonzero if not.

static const uint LOCAL_MAX ;

Indicates the number of local storage pointers available at program startup. It is recommended that this number be at least 64.

static uint createLocal ();

Reserves a local storage pointer for use and initializes this location to null for all running threads.

Returns:
A key representing the array offset of this memory location.

static void deleteLocal (uint key);

Marks the supplied key as available and sets the associated location to null for all running threads. It is assumed that any key passed to this function is valid. The result of calling this function for a key which is still in use is undefined.

Params:

uint key

The key to delete.

static void* getLocal (uint key);

Loads the value stored at key within a thread-local static array. It is assumed that any key passed to this function is valid.

Params:

uint key

The location which holds the desired data.

Returns:
The data associated with the supplied key.

static void* setLocal (uint key, void* val);

Stores the supplied value at key within a thread-local static array. It is assumed that any key passed to this function is valid.

Params:

uint key	The location to store the supplied data.
void* val	The data to store.

Returns:
A copy of the data which has just been stored.

this(T def = T.init);

Initializes thread local storage for the indicated value which will be initialized to def for all threads.

Params:

def	The default value to return if no value has been explicitly set.

T val ();

Gets the value last set by the calling thread, or def if no such value has been set.

Returns:
The stored value or def if no value is stored.

T val (T newval);

Copies newval to a location specific to the calling thread, and returns newval.

Params:

T newval

The value to set.

Returns:
The value passed to this function.

final Thread create (void(* fn)());

Creates and starts a new Thread object that executes fn and adds it to the list of tracked threads.

Params:

void(* fn)()

The thread function.

Returns:
A reference to the newly created thread.

final Thread create (void delegate() dg);

Creates and starts a new Thread object that executes dg and adds it to the list of tracked threads.

Params:

void delegate() dg

The thread function.

Returns:
A reference to the newly created thread.

final void add (Thread t);

Add t to the list of tracked threads if it is not already being tracked.

Params:

Thread t

The thread to add .

In:
t must not be null.

final void remove (Thread t);

Removes t from the list of tracked threads. No operation will be performed if t is not currently being tracked by this object.

Params:

Thread t

The thread to remove .

In:
t must not be null.

final int opApply (int delegate(ref Thread) dg);

Operates on all threads currently tracked by this object.

final void joinAll (bool rethrow = true);

Iteratively joins all tracked threads. This function will block add, remove, and opApply until it completes.

Params:

bool rethrow

Rethrow any unhandled exception which may have caused the current thread to terminate.

Throws:
Any exception not handled by the joined threads.

 class DerivedFiber : Fiber
 {
     this()
     {
         super( &run );
     }

 private :
     void run()
     {
         printf( "Derived fiber running.\n" );
     }
 }

 void fiberFunc()
 {
     printf( "Composed fiber running.\n" );
     Fiber.yield();
     printf( "Composed fiber running.\n" );
 }

 // create instances of each type
 Fiber derived = new DerivedFiber();
 Fiber composed = new Fiber( &fiberFunc );

 // call both fibers once
 derived.call();
 composed.call();
 printf( "Execution returned to calling context.\n" );
 composed.call();

 // since each fiber has run to completion, each should have state TERM
 assert( derived.state == Fiber.State.TERM );
 assert( composed.state == Fiber.State.TERM );

this(void(* fn)(), size_t sz = PAGESIZE);

Initializes a fiber object which is associated with a static D function.

Params:

void(* fn)()	The thread function.
uint sz	The stack size for this fiber.

In:
fn must not be null.

this(void delegate() dg, size_t sz = PAGESIZE);

Initializes a fiber object which is associated with a dynamic D function.

Params:

void delegate() dg	The thread function.
uint sz	The stack size for this fiber.

In:
dg must not be null.

final void call (bool rethrow = true);

Transfers execution to this fiber object. The calling context will be suspended until the fiber calls Fiber.yield() or until it terminates via an unhandled exception.

Params:

bool rethrow

Rethrow any unhandled exception which may have caused this fiber to terminate.

In:
This fiber must be in state HOLD.

Throws:
Any exception not handled by the joined thread.

final void reset ();

Resets this fiber so that it may be re-used. This routine may only be called for fibers that have terminated, as doing otherwise could result in scope-dependent functionality that is not executed. Stack-based classes, for example, may not be cleaned up properly if a fiber is reset before it has terminated.

In:
This fiber must be in state TERM.

enum State ;

A fiber may occupy one of three states: HOLD, EXEC, and TERM. The HOLD state applies to any fiber that is suspended and ready to be called. The EXEC state will be set for any fiber that is currently executing. And the TERM state is set when a fiber terminates. Once a fiber terminates, it must be reset before it may be called again.

HOLD

EXEC

TERM

final State state ();

Gets the current state of this fiber.

Returns:
The state of this fiber as an enumerated value.

static void yield ();

Forces a context switch to occur away from the calling fiber.

static void yieldAndThrow (Object obj);

Forces a context switch to occur away from the calling fiber and then throws obj in the calling fiber.

Params:

Object obj

The object to throw.

In:
obj must not be null.

static Fiber getThis ();

Provides a reference to the calling fiber or null if no fiber is currently active.

Returns:
The fiber object representing the calling fiber or null if no fiber is currently active. The result of deleting this object is undefined.