Package de.eldoria.eldoutilities.scheduling

Class QueuingSelfSchedulingTask<T>

java.lang.Object

de.eldoria.eldoutilities.threading.ReschedulingTask

de.eldoria.eldoutilities.scheduling.QueuingSelfSchedulingTask<T>

Direct Known Subclasses:

DelayedActions

public abstract class QueuingSelfSchedulingTask<T>
extends ReschedulingTask

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	DEFAULT_MAX_DURATION_TARGET
protected static final int	DEFAULT_MAX_IDLE_TICKS

Constructor Summary

Constructors

Constructor	Description
QueuingSelfSchedulingTask(Plugin plugin)
QueuingSelfSchedulingTask(Plugin plugin, int maxIdleTicks, int maxDurationTarget)

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear all the queued objects and cancel the task.
abstract void	execute(T object)	handle one object which was polled from the queue
protected Queue<T>	getQueueImplementation()
protected boolean	proceed(T object)	Define if this object should be polled from queue or if the scheduler should proceed to the next tick.
protected boolean	remove(T o)
protected boolean	removeIf(Predicate<? super T> filter)
final void	run()
protected final void	schedule(T object)
final void	shutdown()	Shuts down the scheduler.
void	tick()	Tick is executed once per tick.

Methods inherited from class de.eldoria.eldoutilities.threading.ReschedulingTask

cancel, getPlugin, isActive, isRunning, schedule

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_DURATION_TARGET

protected static final int DEFAULT_MAX_DURATION_TARGET

See Also:

• Constant Field Values

DEFAULT_MAX_IDLE_TICKS

protected static final int DEFAULT_MAX_IDLE_TICKS

See Also:

• Constant Field Values

Constructor Details

QueuingSelfSchedulingTask

public QueuingSelfSchedulingTask(Plugin plugin,
 int maxIdleTicks,
 int maxDurationTarget)

QueuingSelfSchedulingTask

public QueuingSelfSchedulingTask(Plugin plugin)

Method Details

execute

public abstract void execute(T object)

handle one object which was polled from the queue

Parameters:

object - object from queue

tick

public void tick()

Tick is executed once per tick.

run

public final void run()

Specified by:

run in class ReschedulingTask

proceed

protected boolean proceed(T object)

Define if this object should be polled from queue or if the scheduler should proceed to the next tick.

Parameters:

object - object to check

Returns:

true if the object should be handeld. false if the task should wait.

schedule

protected final void schedule(T object)

getQueueImplementation

protected Queue<T> getQueueImplementation()

shutdown

public final void shutdown()

Description copied from class: ReschedulingTask

Shuts down the scheduler. It can be not scheduled again after this.

Overrides:

shutdown in class ReschedulingTask

clear

public void clear()

Clear all the queued objects and cancel the task. It can be scheduled again after this.

remove

protected boolean remove(T o)

removeIf

protected boolean removeIf(Predicate<? super T> filter)