hera.server

Class StateMachine<StateT>

java.lang.Object

hera.server.StateMachine<StateT>

public class StateMachine<StateT>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Object[]	args
protected java.util.Collection<StateChangeListener<StateT>>	listeners
protected java.util.concurrent.locks.ReentrantReadWriteLock	lock
protected org.slf4j.Logger	logger
protected StateT	state

Constructor Summary

Constructors

Constructor and Description
StateMachine(StateT initialState)

Method Summary

Modifier and Type	Method and Description
void	addListener(StateChangeListener<StateT> listener)
void	changeState(StateT state, java.lang.Object... args) Change current status to state.
boolean	changeState(StateT state, StateCondition<StateT> condition, java.lang.Object... args) Change current state to state if condition is true.
void	execute(java.util.concurrent.Callable<java.lang.Void> process, StateT success, StateT fail) Execute and change state as the result.
protected void	fireChangeEvent(StateT from, StateT to, java.lang.Object... args)
java.lang.Object[]	getArguments() Get arguments.
java.util.concurrent.locks.ReadWriteLock	getLock()
StateT	getState() Return current state.
boolean	isState(StateT... states) Check if current state is one of states.
void	removeListener(StateChangeListener<StateT> listener)
java.lang.String	toString()
void	waitState(StateT... states) Wait that current state is one of states.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

lock

protected java.util.concurrent.locks.ReentrantReadWriteLock lock

listeners

protected java.util.Collection<StateChangeListener<StateT>> listeners

state

protected StateT state

args

protected java.lang.Object[] args

Constructor Detail

StateMachine

public StateMachine(StateT initialState)

Method Detail

getLock

public java.util.concurrent.locks.ReadWriteLock getLock()

addListener

public void addListener(StateChangeListener<StateT> listener)

removeListener

public void removeListener(StateChangeListener<StateT> listener)

isState

public boolean isState(StateT... states)

Check if current state is one of states.

Parameters:

states - states to check

Returns:

if current state is one of states

waitState

public void waitState(StateT... states)

Wait that current state is one of states.

Parameters:

states - states to wait for

getState

public StateT getState()

Return current state.

Returns:

current state

getArguments

public java.lang.Object[] getArguments()

Get arguments.

Returns:

current state's arguments

changeState

public void changeState(StateT state,
                        java.lang.Object... args)

Change current status to state.

Use lock for write.

Parameters:

state - state to change

args - arguments which next state have

changeState

public boolean changeState(StateT state,
                           StateCondition<StateT> condition,
                           java.lang.Object... args)

Change current state to state if condition is true.

Use lock for write

Parameters:

state - state to change

condition - condition to check

args - arguments which next state have

Returns:

if state is changed

execute

public void execute(java.util.concurrent.Callable<java.lang.Void> process,
                    StateT success,
                    StateT fail)

Execute and change state as the result.

Parameters:

process - Callable to execute

success - state to transit when succeed

fail - state to transit when fail

fireChangeEvent

protected void fireChangeEvent(StateT from,
                               StateT to,
                               java.lang.Object... args)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object