Package de.eldoria.eldoutilities.scheduling

Class SelfSchedulingWorker<V,T extends Collection<V>>

java.lang.Object

de.eldoria.eldoutilities.threading.ReschedulingTask

de.eldoria.eldoutilities.scheduling.SelfSchedulingWorker<V,T>

Type Parameters:

V - type of collection

T - type of collection implementation

public abstract class SelfSchedulingWorker<V,T extends Collection<V>>
extends ReschedulingTask

A self scheduling worker which will schedule itself when getting tasks.

Will unschedule itself if no tasks are left for some time.

Since:

1.4.0

Constructor Summary

Constructors

Constructor	Description
SelfSchedulingWorker(org.bukkit.plugin.Plugin plugin)
SelfSchedulingWorker(org.bukkit.plugin.Plugin plugin, int maxIdleTicks)

Method Summary

Modifier and Type	Method	Description
protected abstract void	execute(V object)	handle one object which was polled from the queue
protected abstract T	getQueueImplementation()
protected final void	register(V object)
final void	run()
final void	shutdown()	Shuts down the scheduler.
protected void	tick()	Tick is executed once per tick.
final void	unregister(V object)

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

Constructor Details

SelfSchedulingWorker

public SelfSchedulingWorker(org.bukkit.plugin.Plugin plugin,
 int maxIdleTicks)

SelfSchedulingWorker

public SelfSchedulingWorker(org.bukkit.plugin.Plugin plugin)

Method Details

execute

protected abstract void execute(V object)

handle one object which was polled from the queue

Parameters:

object - object from queue

tick

protected void tick()

Tick is executed once per tick.

run

public final void run()

Specified by:

run in class ReschedulingTask

register

protected final void register(V object)

unregister

public final void unregister(V object)

getQueueImplementation

protected abstract 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