org.fusesource.hawtdispatch.internal

Class BaseSuspendable

java.lang.Object

org.fusesource.hawtdispatch.Task

org.fusesource.hawtdispatch.internal.BaseSuspendable

All Implemented Interfaces:

java.lang.Runnable, Suspendable

Direct Known Subclasses:

AbstractDispatchObject

public class BaseSuspendable
extends Task
implements Suspendable

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicBoolean	startup
protected java.util.concurrent.atomic.AtomicInteger	suspended

Constructor Summary

Constructors

Constructor and Description
BaseSuspendable()

Method Summary

Modifier and Type	Method and Description
boolean	isSuspended()
protected void	onResume()
protected void	onStartup()
protected void	onSuspend()
void	resume() Resumes the invocation of tasks on a dispatch object.
void	run()
void	suspend() Suspends the invocation of tasks on a dispatch object.

Methods inherited from class java.lang.Object

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

Field Detail

startup

protected final java.util.concurrent.atomic.AtomicBoolean startup

suspended

protected final java.util.concurrent.atomic.AtomicInteger suspended

Constructor Detail

BaseSuspendable

public BaseSuspendable()

Method Detail

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface Suspendable

Returns:

true if the the current object is suspended.

See Also:

Suspendable.resume(), Suspendable.suspend()

resume

public void resume()

Description copied from interface: Suspendable

Resumes the invocation of tasks on a dispatch object.

Specified by:

resume in interface Suspendable

See Also:

Suspendable.suspend()

suspend

public void suspend()

Description copied from interface: Suspendable

Suspends the invocation of tasks on a dispatch object.

A suspended object will not invoke any tasks associated with it. The suspension of an object will occur after any running runnable associated with the object completes.

Calls to Suspendable.suspend() must be balanced with calls to Suspendable.resume().

Specified by:

suspend in interface Suspendable

See Also:

Suspendable.resume()

onStartup

protected void onStartup()

onSuspend

protected void onSuspend()

onResume

protected void onResume()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in class Task