Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.util.task
[Java] Class BasicExecutionManager

java.lang.Object
  brooklyn.util.task.BasicExecutionManager
All Implemented Interfaces:
ExecutionManager
public class BasicExecutionManager

TODO javadoc

Method Summary
java.lang.Object BasicExecutionManager(java.lang.String contextid)

void addListener(ExecutionListener listener)

protected void afterEnd(java.util.Map flags, Task task)

protected void beforeStart(java.util.Map flags, Task task)

protected void beforeSubmit(java.util.Map flags, Task task)

boolean clearTaskSchedulerForTag(java.lang.Object tag)

void deleteTag(java.lang.Object tag)

void deleteTask(Task task)

protected boolean deleteTaskNonRecursive(Task task)

long getNumActiveTasks()

long getNumInMemoryTasks()

long getNumIncompleteTasks()

static java.lang.ThreadLocal getPerThreadCurrentTask()

Task getTask(java.lang.String id)

TaskScheduler getTaskSchedulerForTag(java.lang.Object tag)

java.util.Set getTaskTags()

java.util.Set getTasksWithAllTags(java.lang.Iterable tags)

java.util.Set getTasksWithAnyTag(java.lang.Iterable tags)

java.util.Set getTasksWithTag(java.lang.Object tag)

long getTotalTasksSubmitted()

boolean isShutdown()

protected java.util.concurrent.ThreadFactory newThreadFactory(java.lang.String contextid)

For use by overriders to use custom thread factory.

void removeListener(ExecutionListener listener)

Task scheduleWith(Task task)

Task scheduleWith(java.util.Map flags, Task task)

void setTaskSchedulerForTag(java.lang.Object tag, java.lang.Class scheduler)

void setTaskSchedulerForTag(java.lang.Object tag, TaskScheduler scheduler)

Defines a TaskScheduler to run on all subsequently submitted jobs with the given tag.
void shutdownNow()

Task submit(java.lang.Runnable r)

Task submit(java.util.Map flags, java.lang.Runnable r)

Task submit(java.util.concurrent.Callable c)

Task submit(java.util.Map flags, java.util.concurrent.Callable c)

Task submit(TaskAdaptable t)

Task submit(java.util.Map flags, TaskAdaptable task)

protected Task submitNewScheduledTask(java.util.Map flags, ScheduledTask task)

protected Task submitNewTask(java.util.Map flags, Task task)

 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Method Detail

BasicExecutionManager

public java.lang.Object BasicExecutionManager(java.lang.String contextid)

addListener

public void addListener(ExecutionListener listener)

afterEnd

protected void afterEnd(java.util.Map flags, Task task)

beforeStart

protected void beforeStart(java.util.Map flags, Task task)

beforeSubmit

protected void beforeSubmit(java.util.Map flags, Task task)

clearTaskSchedulerForTag

public boolean clearTaskSchedulerForTag(java.lang.Object tag)

deleteTag

public void deleteTag(java.lang.Object tag)

deleteTask

public void deleteTask(Task task)

deleteTaskNonRecursive

protected boolean deleteTaskNonRecursive(Task task)

getNumActiveTasks

public long getNumActiveTasks()

getNumInMemoryTasks

public long getNumInMemoryTasks()

getNumIncompleteTasks

public long getNumIncompleteTasks()

getPerThreadCurrentTask

public static java.lang.ThreadLocal getPerThreadCurrentTask()

getTask

@java.lang.OverrideSet> result = getMutableTasksWithTag(tag);
public Task getTask(java.lang.String id)

getTaskSchedulerForTag

public TaskScheduler getTaskSchedulerForTag(java.lang.Object tag)

getTaskTags

public java.util.Set getTaskTags()

getTasksWithAllTags

@java.lang.OverrideIterator ti = tags.iterator();
public java.util.Set getTasksWithAllTags(java.lang.Iterable tags)

getTasksWithAnyTag

@java.lang.Overridereturn Collections.unmodifiableSet(result);
public java.util.Set getTasksWithAnyTag(java.lang.Iterable tags)

getTasksWithTag

@java.lang.Override
public java.util.Set getTasksWithTag(java.lang.Object tag)

getTotalTasksSubmitted

public long getTotalTasksSubmitted()

isShutdown

public boolean isShutdown()

newThreadFactory

protected java.util.concurrent.ThreadFactory newThreadFactory(java.lang.String contextid)
For use by overriders to use custom thread factory. But be extremely careful: called by constructor, so before sub-class' constructor will have been invoked!

removeListener

public void removeListener(ExecutionListener listener)

scheduleWith

public Task scheduleWith(Task task)

scheduleWith

public Task scheduleWith(java.util.Map flags, Task task)

setTaskSchedulerForTag

public void setTaskSchedulerForTag(java.lang.Object tag, java.lang.Class scheduler)

setTaskSchedulerForTag

public void setTaskSchedulerForTag(java.lang.Object tag, TaskScheduler scheduler)
Defines a TaskScheduler to run on all subsequently submitted jobs with the given tag. Maximum of one allowed currently. Resubmissions of the same scheduler (or scheduler class) allowed. If changing, you must call clearTaskSchedulerForTag(Object) between the two.
See Also:
setTaskSchedulerForTag(Object, Class)

shutdownNow

public void shutdownNow()

submit

public Task submit(java.lang.Runnable r)

submit

public Task submit(java.util.Map flags, java.lang.Runnable r)

submit

public Task submit(java.util.concurrent.Callable c)

submit

public Task submit(java.util.Map flags, java.util.concurrent.Callable c)

submit

public Task submit(TaskAdaptable t)

submit

public Task submit(java.util.Map flags, TaskAdaptable task)

submitNewScheduledTask

@java.lang.SuppressWarningsfinal TaskInternal taskScheduled = (TaskInternal) task.newTask();
protected Task submitNewScheduledTask(java.util.Map flags, ScheduledTask task)

submitNewTask

@java.lang.SuppressWarningsif (((TaskInternal)task).getJob() == null)
protected Task submitNewTask(java.util.Map flags, Task task)

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.