com.atlassian.bamboo.v2.build.queue.order

Class FifoExecutableOrderProvider

java.lang.Object

com.atlassian.bamboo.v2.build.queue.order.FifoExecutableOrderProvider

All Implemented Interfaces:

ExecutableOrderProvider

public class FifoExecutableOrderProvider
extends Object
implements ExecutableOrderProvider

Basic order provider that implements a reorderable FIFO ordering.

Constructor Summary

Constructors

Constructor and Description
FifoExecutableOrderProvider()

Method Summary

Modifier and Type	Method and Description
ResultKey	findExecutableForAgent(long agentId, Collection<QueueOfExecutables.ExecutableData> executableData) From the list of executables, returns the executable that should be picked up by the agent.
Collection<BuildQueueManager.QueuedResultKey>	getOrderedExecutables() Returns a full list of result keys of queued executables ordered with a global ordering.
void	onDequeue(CommonContext context) Called when a context is removed from queue.
void	onEnqueue(Iterable<CommonContext> contexts) Will not be called concurrently.
boolean	reorder(ResultKey resultKey, int index) Called when an executable with a specific result key should be moved to a specific index in the queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

FifoExecutableOrderProvider

public FifoExecutableOrderProvider()

Method Detail

onEnqueue

public void onEnqueue(@NotNull
                      Iterable<CommonContext> contexts)

Description copied from interface: ExecutableOrderProvider

Will not be called concurrently. Called when new context are added to the queue.

Specified by:

onEnqueue in interface ExecutableOrderProvider

onDequeue

public void onDequeue(@NotNull
                      CommonContext context)

Description copied from interface: ExecutableOrderProvider

Called when a context is removed from queue. It may be manually removed from queue (stopped), or sent to and acknowledged by an agent. Will not be called concurrently.

Specified by:

onDequeue in interface ExecutableOrderProvider

findExecutableForAgent

@Nullable
public ResultKey findExecutableForAgent(long agentId,
                                                  @NotNull
                                                  Collection<QueueOfExecutables.ExecutableData> executableData)

Description copied from interface: ExecutableOrderProvider

From the list of executables, returns the executable that should be picked up by the agent. Returns null when there none of the supplied executables is suitable.

Specified by:

findExecutableForAgent in interface ExecutableOrderProvider

getOrderedExecutables

@NotNull
public Collection<BuildQueueManager.QueuedResultKey> getOrderedExecutables()

Description copied from interface: ExecutableOrderProvider

Returns a full list of result keys of queued executables ordered with a global ordering.

Specified by:

getOrderedExecutables in interface ExecutableOrderProvider

Returns:

the returned iterable has to be thread safe.

reorder

public boolean reorder(ResultKey resultKey,
                       int index)

Description copied from interface: ExecutableOrderProvider

Called when an executable with a specific result key should be moved to a specific index in the queue. Can be ignored. Has to be thread safe, will not be mutexed with enq/deq.

Specified by:

reorder in interface ExecutableOrderProvider

Returns:

true if the executable has successfully been moved, false otherwise.