Package com.atlassian.bamboo.plan

Class NonBlockingPlanExecutionServiceImpl

java.lang.Object

com.atlassian.bamboo.plan.NonBlockingPlanExecutionServiceImpl

All Implemented Interfaces:

NonBlockingPlanExecutionService

public class NonBlockingPlanExecutionServiceImpl
extends Object
implements NonBlockingPlanExecutionService

Field Summary

Fields

Modifier and Type	Field	Description
protected final EventLoggingThreadPoolExecutor	executor
protected final PlanExecutionLaunchControl	planExecutionLaunchControl

Constructor Summary

Constructors

Modifier	Constructor	Description
	NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager)
protected	NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager, int maximumThreadCount, long threadIdleTimeout)
protected	NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager, EventLoggingThreadPoolExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	enqueueTrigger(@NotNull Triggerable triggerable, @NotNull Long triggerId, @NotNull BuildDetectionAction buildDetectionAction)	Submits a background task to run PlanExecutionManager.start(com.atlassian.bamboo.plan.cache.ImmutableChain, com.atlassian.bamboo.build.BuildDetectionAction, com.atlassian.bamboo.util.AcquisitionPolicy).
@NotNull ExecutorStats	getExecutorStats()	Stats for the underlying ThreadPoolExecutor
@NotNull QueueActivityStatsDto	getQueueActivityStatsAndRestoreToInitialState()	Gets analytical data from queue activity tracker and bring its initial state - start data collecting from scratch.
Future<Boolean>	shutdown()	Stop accepting any more trigger requests.
@Nullable Future<ExecutionRequestResult>	tryToStart(@NotNull Triggerable triggerable, @NotNull BuildDetectionAction buildDetectionAction)	Submits a background task to run PlanExecutionManager.start(com.atlassian.bamboo.plan.cache.ImmutableChain, com.atlassian.bamboo.build.BuildDetectionAction, com.atlassian.bamboo.util.AcquisitionPolicy).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

planExecutionLaunchControl

protected final PlanExecutionLaunchControl planExecutionLaunchControl

executor

protected final EventLoggingThreadPoolExecutor executor

Constructor Details

NonBlockingPlanExecutionServiceImpl

public NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager)

NonBlockingPlanExecutionServiceImpl

protected NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager,
 int maximumThreadCount,
 long threadIdleTimeout)

NonBlockingPlanExecutionServiceImpl

protected NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager,
 EventLoggingThreadPoolExecutor executor)

Method Details

enqueueTrigger

public void enqueueTrigger(@NotNull
 @NotNull Triggerable triggerable,
 @NotNull
 @NotNull Long triggerId,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction)

Description copied from interface: NonBlockingPlanExecutionService

Submits a background task to run PlanExecutionManager.start(com.atlassian.bamboo.plan.cache.ImmutableChain, com.atlassian.bamboo.build.BuildDetectionAction, com.atlassian.bamboo.util.AcquisitionPolicy). Only one AcquisitionPolicy.IMMEDIATE per planKey + triggerId combination will be queued at any point in time. The task are not guaranteed to be run, they might get dropped if NonBlockingPlanExecutionService.tryToStart(Triggerable, BuildDetectionAction) is called. Rationale is: conditional triggers won't start anyway if there's a 'guaranteed' build run.

To be used with automatic triggers: any auto Trigger can have Trigger Conditions defined

Specified by:

enqueueTrigger in interface NonBlockingPlanExecutionService

tryToStart

@Nullable
public @Nullable Future<ExecutionRequestResult> tryToStart(@NotNull
 @NotNull Triggerable triggerable,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction)

Description copied from interface: NonBlockingPlanExecutionService

Submits a background task to run PlanExecutionManager.start(com.atlassian.bamboo.plan.cache.ImmutableChain, com.atlassian.bamboo.build.BuildDetectionAction, com.atlassian.bamboo.util.AcquisitionPolicy). The task uses AcquisitionPolicy.WAIT. To be used for triggers that are 'unconditional'. In other words, the method should be used for cases where build absolutely, positively needs to trigger (unless encountering internal error or hitting concurrent build limit)

Specified by:

tryToStart in interface NonBlockingPlanExecutionService

Returns:

shutdown

public Future<Boolean> shutdown()

Description copied from interface: NonBlockingPlanExecutionService

Stop accepting any more trigger requests.

Specified by:

shutdown in interface NonBlockingPlanExecutionService

getExecutorStats

@NotNull
public @NotNull ExecutorStats getExecutorStats()

Description copied from interface: NonBlockingPlanExecutionService

Stats for the underlying ThreadPoolExecutor

Specified by:

getExecutorStats in interface NonBlockingPlanExecutionService

Returns:

getQueueActivityStatsAndRestoreToInitialState

@NotNull
public @NotNull QueueActivityStatsDto getQueueActivityStatsAndRestoreToInitialState()

Description copied from interface: NonBlockingPlanExecutionService

Gets analytical data from queue activity tracker and bring its initial state - start data collecting from scratch.

Specified by:

getQueueActivityStatsAndRestoreToInitialState in interface NonBlockingPlanExecutionService

Returns:

QueueActivityStatsDto with stat amounts