com.atlassian.bamboo.plan

Class PlanExecutionLockServiceImpl

java.lang.Object

com.atlassian.bamboo.plan.PlanExecutionLockServiceImpl

All Implemented Interfaces:

PlanExecutionLockService

public class PlanExecutionLockServiceImpl
extends Object
implements PlanExecutionLockService

Constructor Summary

Constructors

Constructor and Description
PlanExecutionLockServiceImpl()

Method Summary

Modifier and Type	Method and Description
<V> V	inlineProcessLocks(TriggerableInternalKey internalKey, AcquisitionPolicy acquisitionPolicy, Callable<V> callable) A parallel locking mechanism that allows a backdoor to the standard lock.
void	interruptLockOwner(TriggerableInternalKey internalKey) Interrupts the owner of the lock represented by TriggerableInternalKey
boolean	isLocked(TriggerableInternalKey internalKey) Checks if the given String has been locked
<V> V	lock(TriggerableInternalKey internalKey, AcquisitionPolicy acquisitionPolicy, Callable<V> callable) Quick note about the implementation Since the acquisition policy AcquisitionPolicy.WAIT can block for an indefinite amount of time we acquire this lock before trying to take the global execution lock otherwise callers to runWhenNoExecutionRequestsAreBeingMade(Callable) in the worst case will wait indefinitely.
<V> V	runWhenNoExecutionRequestsAreBeingMade(Callable<V> callable) Executes the given Callable when there are no requests being made to execute plans

Methods inherited from class java.lang.Object

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

Constructor Detail

PlanExecutionLockServiceImpl

public PlanExecutionLockServiceImpl()

Method Detail

runWhenNoExecutionRequestsAreBeingMade

public <V> V runWhenNoExecutionRequestsAreBeingMade(@NotNull
                                                    Callable<V> callable)
                                             throws Exception

Description copied from interface: PlanExecutionLockService

Executes the given Callable when there are no requests being made to execute plans

Specified by:

runWhenNoExecutionRequestsAreBeingMade in interface PlanExecutionLockService

Type Parameters:

V - callable result type

Parameters:

callable - to execute

Returns:

callable result

Throws:

Exception - if error

isLocked

public boolean isLocked(@NotNull
                        TriggerableInternalKey internalKey)

Description copied from interface: PlanExecutionLockService

Checks if the given String has been locked

Specified by:

isLocked in interface PlanExecutionLockService

Parameters:

internalKey - to check

Returns:

locked state

lock

@Nullable
public <V> V lock(@NotNull
                            TriggerableInternalKey internalKey,
                            @NotNull
                            AcquisitionPolicy acquisitionPolicy,
                            @NotNull
                            Callable<V> callable)
                     throws Exception

Quick note about the implementation Since the acquisition policy AcquisitionPolicy.WAIT can block for an indefinite amount of time we acquire this lock before trying to take the global execution lock otherwise callers to runWhenNoExecutionRequestsAreBeingMade(Callable) in the worst case will wait indefinitely.

Specified by:

lock in interface PlanExecutionLockService

Type Parameters:

V - callable result type

Parameters:

internalKey - to lock

acquisitionPolicy - to acquire the lock

callable - to execute

Returns:

callable result

Throws:

Exception - if error

inlineProcessLocks

@Nullable
public <V> V inlineProcessLocks(@NotNull
                                          TriggerableInternalKey internalKey,
                                          @NotNull
                                          AcquisitionPolicy acquisitionPolicy,
                                          @NotNull
                                          Callable<V> callable)
                                   throws Exception

Description copied from interface: PlanExecutionLockService

A parallel locking mechanism that allows a backdoor to the standard lock. This should only be used for short lived locking (whereas the standard lock might be used for change detection). This is by convention only, so take care. This lock will participate in PlanExecutionLockService.isLocked(TriggerableInternalKey) and PlanExecutionLockService.interruptLockOwner(TriggerableInternalKey)

Specified by:

inlineProcessLocks in interface PlanExecutionLockService

Returns:

Throws:

Exception

interruptLockOwner

public void interruptLockOwner(@NotNull
                               TriggerableInternalKey internalKey)

Description copied from interface: PlanExecutionLockService

Interrupts the owner of the lock represented by TriggerableInternalKey

Specified by:

interruptLockOwner in interface PlanExecutionLockService