T
- Actor type.public class ThreadPoolActionEngine.ThreadPoolContext<T> extends AbstractFutureActionContext<T> implements java.lang.Runnable
Modifier | Constructor and Description |
---|---|
protected |
ThreadPoolContext(Action<T> action)
Creates new instance of ThreadPoolContext.
|
Modifier and Type | Method and Description |
---|---|
<S> S |
get(java.lang.String key)
Gets the value bound to the supplied key.
|
Action<T> |
getAction()
Gets the action this context is for.
|
T |
getActor()
Gets the associated actor.
|
ActionEngine |
getEngine()
Gets the associated engine.
|
long |
getInitialDelay(java.util.concurrent.TimeUnit unit)
Gets the initial delay.
|
long |
getPeriod(java.util.concurrent.TimeUnit unit)
Gets the actions repeat period.
|
boolean |
isPeriodicOnException()
Whether the action will continue to reschedule on exception.
|
<S> S |
put(java.lang.String key,
S value)
Binds the supplied key-value pair.
|
void |
putAll(java.util.Map<java.lang.String,?> map)
Binds all of the key-value pairs in the supplied map.
|
<S> S |
remove(java.lang.String key)
Removes the value bound to the supplied key.
|
void |
removeAll()
Removes all key-value pairs.
|
void |
run() |
void |
schedule()
Schedules the action for execution.
|
void |
setActor(T actor)
Sets the referenced actor.
|
void |
setInitialDelay(long initialDelay,
java.util.concurrent.TimeUnit unit)
Sets the initial delay.
|
void |
setPeriod(long period,
java.util.concurrent.TimeUnit unit)
Sets the period.
|
void |
setPeriodicOnException(boolean periodicOnException)
Sets whether the action continues to reschedule after an exception.
|
java.util.Map<java.lang.String,?> |
toMap()
Maps the key-values combinations.
|
await, cancel, getFuture, isCancelled, isDone, setFuture
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
scheduleAndAwait
getOptActor, hasActor, isPeriodic
containsKey
public void run()
run
in interface java.lang.Runnable
public void schedule()
SchedulableActionContext
schedule
in interface SchedulableActionContext<T>
public <S> S get(java.lang.String key)
ActionBindings
get
in interface ActionBindings
key
- Key to check.public Action<T> getAction()
SchedulableActionContext
getAction
in interface SchedulableActionContext<T>
public T getActor()
ActionContext
getActor
in interface ActionContext<T>
public ActionEngine getEngine()
ActionContext
getEngine
in interface ActionContext<T>
public long getInitialDelay(java.util.concurrent.TimeUnit unit)
SchedulableActionContext
getInitialDelay
in interface SchedulableActionContext<T>
unit
- TimeUnit to convert to.public long getPeriod(java.util.concurrent.TimeUnit unit)
ActionContext
getPeriod
in interface ActionContext<T>
unit
- TimeUnit to convert period to.public boolean isPeriodicOnException()
ActionContext
isPeriodicOnException
in interface ActionContext<T>
public <S> S put(java.lang.String key, S value)
ActionBindings
put
in interface ActionBindings
key
- Key to bind value to.value
- Value to bind.public void putAll(java.util.Map<java.lang.String,?> map)
ActionBindings
putAll
in interface ActionBindings
map
- Key-value pairs to bind.public <S> S remove(java.lang.String key)
ActionBindings
remove
in interface ActionBindings
key
- Key to check.public void removeAll()
ActionBindings
removeAll
in interface ActionBindings
public void setActor(T actor)
SchedulableActionContext
setActor
in interface SchedulableActionContext<T>
actor
- Actor.public void setInitialDelay(long initialDelay, java.util.concurrent.TimeUnit unit)
SchedulableActionContext
setInitialDelay
in interface SchedulableActionContext<T>
initialDelay
- Initial delay to set (can be 0
).unit
- TimeUnit delay is in.public void setPeriod(long period, java.util.concurrent.TimeUnit unit)
SchedulableActionContext
setPeriod
in interface SchedulableActionContext<T>
period
- Period to set (can be 0
).unit
- TimeUnit period is in.public void setPeriodicOnException(boolean periodicOnException)
SchedulableActionContext
setPeriodicOnException
in interface SchedulableActionContext<T>
periodicOnException
- Whether the action should continue.public java.util.Map<java.lang.String,?> toMap()
ActionBindings
toMap
in interface ActionBindings