edu.rice.hj.continuation

Class Coroutine

java.lang.Object

edu.rice.hj.continuation.Coroutine

All Implemented Interfaces:

Runnable

public class Coroutine
extends Object
implements Runnable

A Coroutine is used to run a CoroutineProto. It also provides a function to suspend a running Coroutine.

Author:

Matthias Mann

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_STACK_SIZE Default stack size for the data stack.
protected YieldReason	reason

Constructor Summary

Constructors

Constructor and Description
Coroutine(CoroutineProto proto) Creates a new Coroutine from the given CoroutineProto.
Coroutine(CoroutineProto proto, int stackSize) Creates a new Coroutine from the given CoroutineProto.

Method Summary

Modifier and Type	Method and Description
protected static Coroutine	getActiveCoroutine() Returns the active Coroutine on this thread or NULL if no coroutine is running.
CoroutineProto	getProto() Returns the CoroutineProto that is used for this Coroutine
YieldReason	getReason()
CoroutineState	getState() Returns the current state of this Coroutine.
void	markCompleted()
void	run() Runs the Coroutine until it is finished or suspended.
static void	yield() Suspend the currently running Coroutine on the calling thread.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_STACK_SIZE

public static final int DEFAULT_STACK_SIZE

Default stack size for the data stack.

See Also:

Coroutine(edu.rice.hj.continuation.CoroutineProto, int), Constant Field Values

reason

protected YieldReason reason

Constructor Detail

Coroutine

public Coroutine(CoroutineProto proto)

Creates a new Coroutine from the given CoroutineProto. A CoroutineProto can be used in several Coroutines at the same time - but then the normal multi threading rules apply to the member state.

Parameters:

proto - the CoroutineProto for the Coroutine.

Coroutine

public Coroutine(CoroutineProto proto,
                 int stackSize)

Creates a new Coroutine from the given CoroutineProto. A CoroutineProto can be used in several Coroutines at the same time - but then the normal multi threading rules apply to the member state.

Parameters:

proto - the CoroutineProto for the Coroutine.

stackSize - the initial stack size for the data stack

Throws:

NullPointerException - when proto is null

IllegalArgumentException - when stackSize is <= 0

Method Detail

yield

public static void yield()
                  throws SuspendableException,
                         IllegalStateException

Suspend the currently running Coroutine on the calling thread.

Throws:

SuspendableException - This exception is used for control transfer - don't catch it !

IllegalStateException - If not called from a Coroutine

getActiveCoroutine

protected static Coroutine getActiveCoroutine()

Returns the active Coroutine on this thread or NULL if no coroutine is running.

Returns:

the active Coroutine on this thread or NULL if no coroutine is running.

getProto

public CoroutineProto getProto()

Returns the CoroutineProto that is used for this Coroutine

Returns:

The CoroutineProto that is used for this Coroutine

getState

public CoroutineState getState()

Returns the current state of this Coroutine. May be called by the Coroutine itself but should not be called by another thread.

The Coroutine starts in the state NEW then changes to RUNNING. From RUNNING it may change to FINISHED or SUSPENDED. SUSPENDED can only change to RUNNING by calling run() again.

Returns:

The current state of this Coroutine

See Also:

run()

markCompleted

public void markCompleted()

getReason

public YieldReason getReason()

run

public void run()
         throws IllegalStateException

Runs the Coroutine until it is finished or suspended. This method must only be called when the Coroutine is in the states NEW or SUSPENDED. It is not multi threading safe.

Specified by:

run in interface Runnable

Throws:

IllegalStateException - if the Coroutine is currently running or already finished.