|
Brooklyn | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbrooklyn.util.task.BasicTask
brooklyn.util.task.DynamicSequentialTask
public class DynamicSequentialTask extends BasicTask
Represents a task whose run() method can create other tasks which are run sequentially, but that sequence runs in parallel to this task
Nested Class Summary | |
---|---|
protected class |
DynamicSequentialTask.DstJob
|
Field Summary | |
---|---|
protected java.lang.Object |
jobTransitionLock
|
protected boolean |
primaryFinished
|
protected boolean |
primaryStarted
|
protected java.lang.Thread |
primaryThread
|
protected java.util.Queue |
secondaryJobsAll
|
protected java.util.Queue |
secondaryJobsRemaining
|
Fields inherited from class BasicTask | |
---|---|
NO_OP, WARN_IF_NOT_RUN, blockingDetails, blockingTask, description, displayName, em, endTimeUtc, job, listeners, queuedTimeUtc, result, startTimeUtc, submitTimeUtc, submittedByTask, tags, thread |
Constructor Summary | |
DynamicSequentialTask()
Constructs a new compound task containing the specified units of work. |
|
DynamicSequentialTask(java.util.concurrent.Callable mainJob)
|
|
DynamicSequentialTask(java.util.Map flags, java.util.concurrent.Callable mainJob)
|
Method Summary | |
---|---|
boolean
|
cancel(boolean mayInterruptIfRunning)
|
java.lang.Iterable
|
getChildren()
|
java.util.List
|
getQueue()
|
void
|
handleException(java.lang.Throwable throwable)
|
Task
|
last()
|
void
|
queue(Task t)
|
protected void
|
submitBackgroundInheritingContext(Task task)
submits the indicated task for execution in the current execution context, and returns immediately |
Field Detail |
---|
protected final java.lang.Object jobTransitionLock
protected boolean primaryFinished
protected boolean primaryStarted
protected java.lang.Thread primaryThread
protected final java.util.Queue secondaryJobsAll
protected final java.util.Queue secondaryJobsRemaining
Constructor Detail |
---|
public DynamicSequentialTask()
jobs
- A potentially heterogeneous mixture of java.lang.Runnable, java.util.concurrent.Callable, groovy.lang.Closure and Task can be provided.
public DynamicSequentialTask(java.util.concurrent.Callable mainJob)
public DynamicSequentialTask(java.util.Map flags, java.util.concurrent.Callable mainJob)
Method Detail |
---|
@Override public boolean cancel(boolean mayInterruptIfRunning)
@Override public java.lang.Iterable getChildren()
// allow checked exceptions to be passed through public java.util.List getQueue()
public void handleException(java.lang.Throwable throwable)
} public Task last()
@Override public void queue(Task t)
protected void submitBackgroundInheritingContext(Task task)
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.