|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jvnet.hudson.reactor.Reactor
public class Reactor
Executes a set of Task
s that dependend on each other.
As a Set
, this object represents a read-only view of all Task
s.
Constructor Summary | |
---|---|
Reactor(java.util.Collection<? extends TaskBuilder> builders)
|
|
Reactor(TaskBuilder... builders)
|
Method Summary | |
---|---|
void |
add(Task t)
Adds a new Task to the reactor. |
void |
addAll(java.lang.Iterable<? extends Task> _tasks)
Adds a set of taks to the reactor. |
void |
execute(java.util.concurrent.Executor e)
|
void |
execute(java.util.concurrent.Executor e,
ReactorListener listener)
Executes this initialization session with the given executor. |
java.util.Iterator<org.jvnet.hudson.reactor.Reactor.Node> |
iterator()
|
protected void |
runTask(Task t)
Can be overridden by the subtype to enclose the entire execution of the task. |
int |
size()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Reactor(java.util.Collection<? extends TaskBuilder> builders) throws java.io.IOException
java.io.IOException
public Reactor(TaskBuilder... builders) throws java.io.IOException
java.io.IOException
Method Detail |
---|
public java.util.Iterator<org.jvnet.hudson.reactor.Reactor.Node> iterator()
iterator
in interface java.lang.Iterable<org.jvnet.hudson.reactor.Reactor.Node>
public int size()
public void execute(java.util.concurrent.Executor e) throws java.lang.InterruptedException, ReactorException
java.lang.InterruptedException
ReactorException
public void add(Task t)
Task
to the reactor.
This can be even invoked during execution.
public void addAll(java.lang.Iterable<? extends Task> _tasks)
When adding a series of related tasks, it's often necessary to add them as a bulk, or else the newly added task can start executing before its dependencies are added.
public void execute(java.util.concurrent.Executor e, ReactorListener listener) throws java.lang.InterruptedException, ReactorException
e
- Used for executing Task
s.listener
- Receives callbacks during the execution.
java.lang.InterruptedException
- if this thread is interrupted while waiting for the execution of tasks to complete.
ReactorException
- if one of the tasks failed by throwing an exception. The caller is responsible for canceling
existing Task
s that are in progress in Executor
, if that's desired.protected void runTask(Task t) throws java.lang.Exception
java.lang.Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |