public DefaultTaskGraphExecuter(ListenerManager listenerManager, TaskPlanExecutor taskPlanExecutor, Factory<? extends TaskExecuter> taskExecuter, BuildCancellationToken cancellationToken, BuildOperationExecutor buildOperationExecutor) { this.taskPlanExecutor = taskPlanExecutor; this.taskExecuter = taskExecuter; this.buildOperationExecutor = buildOperationExecutor; graphListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionGraphListener.class); taskListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionListener.class); internalTaskListener = listenerManager.getBroadcaster(InternalTaskExecutionListener.class); taskExecutionPlan = new DefaultTaskExecutionPlan(cancellationToken); }
public void whenReady(final Action<TaskExecutionGraph> action) { graphListeners.add(new TaskExecutionGraphListener() { @Override public void graphPopulated(TaskExecutionGraph graph) { action.execute(graph); } }); }
public void addTaskExecutionGraphListener(TaskExecutionGraphListener listener) { graphListeners.add(listener); }
public void removeTaskExecutionGraphListener(TaskExecutionGraphListener listener) { graphListeners.remove(listener); }
public DefaultTaskGraphExecuter(ListenerManager listenerManager, TaskPlanExecutor taskPlanExecutor, BuildCancellationToken cancellationToken) { this.taskPlanExecutor = taskPlanExecutor; graphListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionGraphListener.class); taskListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionListener.class); taskExecutionPlan = new DefaultTaskExecutionPlan(cancellationToken); }
public DefaultTaskGraphExecuter(ListenerManager listenerManager, TaskPlanExecutor taskPlanExecutor) { this.taskPlanExecutor = taskPlanExecutor; graphListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionGraphListener.class); taskListeners = listenerManager.createAnonymousBroadcaster(TaskExecutionListener.class); }