de.dytanic.cloudnet.lib.scheduler

Class TaskScheduler

java.lang.Object

de.dytanic.cloudnet.lib.scheduler.TaskScheduler

public class TaskScheduler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TaskScheduler.VoidTaskEntry
class	TaskScheduler.Worker

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	dynamicWorkerCount
protected Logger	logger
protected int	maxThreads
protected String	name
private static TaskScheduler	RUNTIME_SCHEDULER
protected long	sleepThreadSwitch
protected Deque<TaskEntry<?>>	taskEntries
protected ThreadGroup	threadGroup
protected AtomicLong	threadId
protected long	threadLiveMillis
protected Collection<TaskScheduler.Worker>	workers

Constructor Summary

Constructors

Constructor and Description
TaskScheduler()
TaskScheduler(Collection<TaskEntry<?>> entries)
TaskScheduler(Collection<TaskEntry<?>> entries, Logger logger)
TaskScheduler(Collection<TaskEntry<?>> entries, Logger logger, long sleepThreadSwtich)
TaskScheduler(Collection<TaskEntry<?>> entries, long sleepThreadSwtich)
TaskScheduler(int maxThreads)
TaskScheduler(int maxThreads, boolean dynamicWorkerCount)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, Logger logger)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, Logger logger, boolean dynamicWorkerCount)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, Logger logger, long sleepThreadSwitch)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, Logger logger, long sleepThreadSwitch, boolean dynamicThreadCount)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, Logger logger, long sleepThreadSwitch, boolean dynamicThreadCount, long threadLiveMillis)
TaskScheduler(int maxThreads, Collection<TaskEntry<?>> entries, long sleepThreadSwitch)
TaskScheduler(int maxThreads, Logger logger)
TaskScheduler(int maxThreads, Logger logger, boolean dynamicWorkerCount)
TaskScheduler(int maxThreads, Logger logger, long sleepThreadSwitch)
TaskScheduler(int maxThreads, long sleepThreadSwitch)
TaskScheduler(Logger logger)
TaskScheduler(Logger logger, long sleepThreadSwitch)
TaskScheduler(long sleepThreadSwitch)

Method Summary

Modifier and Type	Method and Description
TaskScheduler	chargeThreadLimit(short threads)
private void	checkEnougthThreads()
int	getCurrentThreadSize()
Logger	getLogger()
int	getMaxThreads()
String	getName()
Deque<TaskEntry<?>>	getThreadEntries()
ThreadGroup	getThreadGroup()
private TaskScheduler.Worker	hasFreeWorker()
protected void	newWorker()
private <V> TaskEntryFuture<V>	offerEntry(TaskEntry<V> entry)
static TaskScheduler	runtimeScheduler()
<V> TaskEntryFuture<V>	schedule(Callable<V> callable)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, Instant instant)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, Instant instant, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, LocalDate localDate, LocalTime localTime)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, LocalDate localDate, LocalTime localTime, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, LocalDateTime localDateTime)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, LocalDateTime localDateTime, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, long delay)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, long delay, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, long delay, TimeUnit timeUnit)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, long delay, TimeUnit timeUnit, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, ZonedDateTime zonedDateTime)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Callback<V> callback, ZonedDateTime zonedDateTime, long repeats)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, Instant instant)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, LocalDate localDate, LocalTime localTime)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, LocalDateTime localDateTime)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, long delay)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, long delay, TimeUnit timeUnit)
<V> TaskEntryFuture<V>	schedule(Callable<V> callable, ZonedDateTime zonedDateTime)
<V> Collection<TaskEntryFuture<V>>	schedule(Collection<TaskEntry<V>> threadEntries)
TaskEntryFuture<Void>	schedule(Runnable runnable)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, Date timeout)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, Date timeout, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, Instant instant)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, Instant instant, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, LocalDate localDate, LocalTime localTime)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, LocalDate localDate, LocalTime localTime, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, LocalDateTime localDateTime)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, LocalDateTime localDateTime, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, long delay)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, long delay, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, long delay, TimeUnit timeUnit)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, long delay, TimeUnit timeUnit, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, ZonedDateTime zonedDateTime)
TaskEntryFuture<Void>	schedule(Runnable runnable, Callback<Void> callback, ZonedDateTime zonedDateTime, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Date timeout)
TaskEntryFuture<Void>	schedule(Runnable runnable, Date timeout, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, Instant instant)
TaskEntryFuture<Void>	schedule(Runnable runnable, LocalDate localDate, LocalTime localTime)
TaskEntryFuture<Void>	schedule(Runnable runnable, LocalDateTime localDateTime)
TaskEntryFuture<Void>	schedule(Runnable runnable, long delay)
TaskEntryFuture<Void>	schedule(Runnable runnable, long delay, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, long delay, TimeUnit timeUnit)
TaskEntryFuture<Void>	schedule(Runnable runnable, long delay, TimeUnit timeUnit, long repeats)
TaskEntryFuture<Void>	schedule(Runnable runnable, ZonedDateTime zonedDateTime)
<V> TaskEntryFuture<V>	schedule(TaskEntry<V> taskEntry)
void	setLogger(Logger logger)
Collection<TaskEntry<?>>	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

RUNTIME_SCHEDULER

private static final TaskScheduler RUNTIME_SCHEDULER

threadGroup

protected final ThreadGroup threadGroup

threadId

protected final AtomicLong threadId

name

protected final String name

sleepThreadSwitch

protected final long sleepThreadSwitch

dynamicWorkerCount

protected final boolean dynamicWorkerCount

threadLiveMillis

protected final long threadLiveMillis

maxThreads

protected int maxThreads

logger

protected Logger logger

taskEntries

protected Deque<TaskEntry<?>> taskEntries

workers

protected Collection<TaskScheduler.Worker> workers

Constructor Detail

TaskScheduler

public TaskScheduler()

TaskScheduler

public TaskScheduler(int maxThreads)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Logger logger)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     Logger logger)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     Logger logger,
                     long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     Logger logger,
                     long sleepThreadSwitch,
                     boolean dynamicThreadCount)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     Logger logger,
                     long sleepThreadSwitch,
                     boolean dynamicThreadCount,
                     long threadLiveMillis)

TaskScheduler

public TaskScheduler(long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(int maxThreads,
                     long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Logger logger,
                     long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(Logger logger)

TaskScheduler

public TaskScheduler(Logger logger,
                     long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(Collection<TaskEntry<?>> entries)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries)

TaskScheduler

public TaskScheduler(Collection<TaskEntry<?>> entries,
                     long sleepThreadSwtich)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     long sleepThreadSwitch)

TaskScheduler

public TaskScheduler(Collection<TaskEntry<?>> entries,
                     Logger logger)

TaskScheduler

public TaskScheduler(Collection<TaskEntry<?>> entries,
                     Logger logger,
                     long sleepThreadSwtich)

TaskScheduler

public TaskScheduler(int maxThreads,
                     boolean dynamicWorkerCount)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Logger logger,
                     boolean dynamicWorkerCount)

TaskScheduler

public TaskScheduler(int maxThreads,
                     Collection<TaskEntry<?>> entries,
                     Logger logger,
                     boolean dynamicWorkerCount)

Method Detail

runtimeScheduler

public static TaskScheduler runtimeScheduler()

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      long delay)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      long delay,
                                      long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(TaskEntry<V> taskEntry)

offerEntry

private <V> TaskEntryFuture<V> offerEntry(TaskEntry<V> entry)

checkEnougthThreads

private void checkEnougthThreads()

hasFreeWorker

private TaskScheduler.Worker hasFreeWorker()

getCurrentThreadSize

public int getCurrentThreadSize()

getMaxThreads

public int getMaxThreads()

newWorker

protected void newWorker()

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Date timeout)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      long delay)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      LocalDate localDate,
                                      LocalTime localTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      LocalDate localDate,
                                      LocalTime localTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      LocalDate localDate,
                                      LocalTime localTime,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      LocalDateTime localDateTime,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      ZonedDateTime zonedDateTime,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      Instant instant,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      LocalDateTime localDateTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      LocalDateTime localDateTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      ZonedDateTime zonedDateTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      ZonedDateTime zonedDateTime)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Instant instant)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      Instant instant)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      Date timeout)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      long delay,
                                      TimeUnit timeUnit)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      long delay,
                                      TimeUnit timeUnit)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Date timeout,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      long delay,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      long delay,
                                      TimeUnit timeUnit,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      Date timeout,
                                      long repeats)

schedule

public TaskEntryFuture<Void> schedule(Runnable runnable,
                                      Callback<Void> callback,
                                      long delay,
                                      TimeUnit timeUnit,
                                      long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       long delay)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       long delay,
                                       long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       LocalDate localDate,
                                       LocalTime localTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       LocalDate localDate,
                                       LocalTime localTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       LocalDate localDate,
                                       LocalTime localTime,
                                       long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       LocalDateTime localDateTime,
                                       long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       ZonedDateTime zonedDateTime,
                                       long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       Instant instant,
                                       long repeats)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       LocalDateTime localDateTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       LocalDateTime localDateTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       ZonedDateTime zonedDateTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       ZonedDateTime zonedDateTime)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Instant instant)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       Instant instant)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       long delay)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       long delay,
                                       TimeUnit timeUnit)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       long delay,
                                       TimeUnit timeUnit)

schedule

public <V> TaskEntryFuture<V> schedule(Callable<V> callable,
                                       Callback<V> callback,
                                       long delay,
                                       TimeUnit timeUnit,
                                       long repeats)

schedule

public <V> Collection<TaskEntryFuture<V>> schedule(Collection<TaskEntry<V>> threadEntries)

shutdown

public Collection<TaskEntry<?>> shutdown()

chargeThreadLimit

public TaskScheduler chargeThreadLimit(short threads)

getThreadGroup

public ThreadGroup getThreadGroup()

getName

public String getName()

getThreadEntries

public Deque<TaskEntry<?>> getThreadEntries()

getLogger

public Logger getLogger()

setLogger

public void setLogger(Logger logger)