com.atlassian.bamboo.plan
Class NonBlockingPlanExecutionServiceImpl

java.lang.Object
  com.atlassian.bamboo.plan.NonBlockingPlanExecutionServiceImpl

All Implemented Interfaces:

NonBlockingPlanExecutionService

public class NonBlockingPlanExecutionServiceImpl
extends java.lang.Object
implements NonBlockingPlanExecutionService

Constructor Summary

NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager, ImmutablePlanCacheService immutablePlanCacheService)

Method Summary

ExecutorStats	getExecutorStats() Stats for the underlying ThreadPoolExecutor
java.util.concurrent.Future<ExecutionRequestResult>	tryToStart(ImmutableChain chain, BuildDetectionAction buildDetectionAction, AcquisitionPolicy acquisitionPolicy) 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

Constructor Detail

NonBlockingPlanExecutionServiceImpl

public NonBlockingPlanExecutionServiceImpl(PlanExecutionManager planExecutionManager,
                                           ImmutablePlanCacheService immutablePlanCacheService)

Method Detail

tryToStart

@Nullable
public java.util.concurrent.Future<ExecutionRequestResult> tryToStart(@NotNull
                                                                               ImmutableChain chain,
                                                                               @NotNull
                                                                               BuildDetectionAction buildDetectionAction,
                                                                               @NotNull
                                                                               AcquisitionPolicy acquisitionPolicy)

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 will be queued at any point in time.

Specified by:

tryToStart in interface NonBlockingPlanExecutionService

Returns:

getExecutorStats

@NotNull
public ExecutorStats getExecutorStats()

Description copied from interface: NonBlockingPlanExecutionService

Stats for the underlying ThreadPoolExecutor

Specified by:

getExecutorStats in interface NonBlockingPlanExecutionService

Returns: