Package org.sterl.spring.persistent_tasks.scheduler.component

Class RunOrQueueComponent

java.lang.Object

org.sterl.spring.persistent_tasks.scheduler.component.RunOrQueueComponent

public class RunOrQueueComponent
extends Object

Not a spring bean!

Constructor Summary

Constructors

Constructor	Description
RunOrQueueComponent()

Method Summary

Modifier and Type	Method	Description
boolean	checkIfTrigerShouldRun(long triggerId)
void	clear()
<T extends Serializable> TriggerKey	execute(AddTriggerRequest<T> triggerRequest)	Runs the given trigger if a free threads are available and the runAt time is not in the future.
boolean	hasWaitingTriggers()

Methods inherited from class java.lang.Object

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

Constructor Details

RunOrQueueComponent

public RunOrQueueComponent()

Method Details

execute

public <T extends Serializable> TriggerKey execute(AddTriggerRequest<T> triggerRequest)

Runs the given trigger if a free threads are available and the runAt time is not in the future.

Returns:

the reference to the Future with the key, if no threads are available it is resolved

checkIfTrigerShouldRun

public boolean checkIfTrigerShouldRun(long triggerId)

hasWaitingTriggers

public boolean hasWaitingTriggers()

clear

public void clear()