org.jvnet.hudson.reactor
public class Reactor extends java.lang.Object implements java.lang.Iterable<org.jvnet.hudson.reactor.Reactor.Node>
Task
s that dependend on each other.
As a Set
, this object represents a read-only view of all Task
s.
Constructor and Description |
---|
Reactor(java.util.Collection<? extends TaskBuilder> builders) |
Reactor(TaskBuilder... builders) |
Modifier and Type | Method and Description |
---|---|
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() |
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
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
Copyright © 2014. All Rights Reserved.