Package de.dytanic.cloudnet.common.concurrent

Class DefaultTaskScheduler

java.lang.Object

de.dytanic.cloudnet.common.concurrent.DefaultTaskScheduler

All Implemented Interfaces:

IScheduledTaskInvoker, ITaskScheduler, java.util.concurrent.Executor

public class DefaultTaskScheduler
extends java.lang.Object
implements ITaskScheduler

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	DEFAULT_THREAD_LIFE_MILLIS
protected static long	DEFAULT_THREAD_PAUSE_MILLIS
protected static java.util.concurrent.atomic.AtomicInteger	GROUP_COUNT
protected int	maxThreadSize
protected java.util.Deque<IScheduledTask<?>>	taskEntries
protected java.util.concurrent.atomic.AtomicLong	THREAD_COUNT
protected java.lang.ThreadGroup	threadGroup
protected long	threadLifeMillis
protected long	threadPauseDelayMillis
protected java.util.Queue<IWorkableThread>	workers

Constructor Summary

Constructors

Constructor	Description
DefaultTaskScheduler()
DefaultTaskScheduler(int maxThreadSize)
DefaultTaskScheduler(int maxThreadSize, long threadLifeMillis, long threadPauseDelayMillis)

Method Summary

Modifier and Type	Method	Description
ITaskScheduler	cancelAll()
IWorkableThread	createWorker()
void	execute(@NotNull java.lang.Runnable command)
int	getCurrentWorkerCount()
static long	getDefaultThreadLifeMillis()
static long	getDefaultThreadPauseMillis()
static java.util.concurrent.atomic.AtomicInteger	getGroupCount()
int	getMaxThreadSize()
java.util.Deque<IScheduledTask<?>>	getTaskEntries()
java.util.concurrent.atomic.AtomicLong	getTHREAD_COUNT()
java.lang.ThreadGroup	getThreadGroup()
long	getThreadLifeMillis()
long	getThreadPauseDelayMillis()
java.util.Collection<IWorkableThread>	getWorkers()
IWorkableThread	hasFreeWorker()
<V> IScheduledTask<V>	offerTask(IScheduledTask<V> scheduledTask)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay, long repeat)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay, long repeat, long repeats)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay, long repeat, long repeats, java.util.concurrent.TimeUnit timeUnit)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay, long repeat, java.util.concurrent.TimeUnit timeUnit)
IScheduledTask<java.lang.Void>	schedule(java.lang.Runnable runnable, long delay, java.util.concurrent.TimeUnit timeUnit)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, long repeat)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, long repeat, long repeats)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, long repeat, long repeats, java.util.concurrent.TimeUnit timeUnit)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, long repeat, java.util.concurrent.TimeUnit timeUnit)
<V> IScheduledTask<V>	schedule(java.util.concurrent.Callable<V> callable, long delay, java.util.concurrent.TimeUnit timeUnit)
void	setMaxThreadSize(int maxThreadSize)
void	setThreadLifeMillis(long threadLifeMillis)
void	setThreadPauseDelayMillis(long threadPauseDelayMillis)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_THREAD_LIFE_MILLIS

protected static final long DEFAULT_THREAD_LIFE_MILLIS

See Also:

Constant Field Values

DEFAULT_THREAD_PAUSE_MILLIS

protected static final long DEFAULT_THREAD_PAUSE_MILLIS

See Also:

Constant Field Values

GROUP_COUNT

protected static final java.util.concurrent.atomic.AtomicInteger GROUP_COUNT

taskEntries

protected final java.util.Deque<IScheduledTask<?>> taskEntries

workers

protected final java.util.Queue<IWorkableThread> workers

threadGroup

protected final java.lang.ThreadGroup threadGroup

THREAD_COUNT

protected final java.util.concurrent.atomic.AtomicLong THREAD_COUNT

maxThreadSize

protected volatile int maxThreadSize

threadLifeMillis

protected volatile long threadLifeMillis

threadPauseDelayMillis

protected volatile long threadPauseDelayMillis

Constructor Detail

DefaultTaskScheduler

public DefaultTaskScheduler()

DefaultTaskScheduler

public DefaultTaskScheduler(int maxThreadSize)

DefaultTaskScheduler

public DefaultTaskScheduler(int maxThreadSize,
                            long threadLifeMillis,
                            long threadPauseDelayMillis)

Method Detail

getDefaultThreadLifeMillis

public static long getDefaultThreadLifeMillis()

getDefaultThreadPauseMillis

public static long getDefaultThreadPauseMillis()

getGroupCount

public static java.util.concurrent.atomic.AtomicInteger getGroupCount()

getTaskEntries

public java.util.Deque<IScheduledTask<?>> getTaskEntries()

getThreadGroup

public java.lang.ThreadGroup getThreadGroup()

getTHREAD_COUNT

public java.util.concurrent.atomic.AtomicLong getTHREAD_COUNT()

getMaxThreadSize

public int getMaxThreadSize()

Specified by:

getMaxThreadSize in interface ITaskScheduler

setMaxThreadSize

public void setMaxThreadSize(int maxThreadSize)

getThreadLifeMillis

public long getThreadLifeMillis()

Specified by:

getThreadLifeMillis in interface ITaskScheduler

setThreadLifeMillis

public void setThreadLifeMillis(long threadLifeMillis)

Specified by:

setThreadLifeMillis in interface ITaskScheduler

getThreadPauseDelayMillis

public long getThreadPauseDelayMillis()

setThreadPauseDelayMillis

public void setThreadPauseDelayMillis(long threadPauseDelayMillis)

getCurrentWorkerCount

public int getCurrentWorkerCount()

Specified by:

getCurrentWorkerCount in interface ITaskScheduler

createWorker

public IWorkableThread createWorker()

Specified by:

createWorker in interface ITaskScheduler

hasFreeWorker

public IWorkableThread hasFreeWorker()

Specified by:

hasFreeWorker in interface ITaskScheduler

getWorkers

public java.util.Collection<IWorkableThread> getWorkers()

Specified by:

getWorkers in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay,
                                      java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay,
                                      long repeat)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay,
                                      long repeat,
                                      java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay,
                                      long repeat,
                                      long repeats)

Specified by:

schedule in interface ITaskScheduler

schedule

public <V> IScheduledTask<V> schedule(java.util.concurrent.Callable<V> callable,
                                      long delay,
                                      long repeat,
                                      long repeats,
                                      java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay,
                                               java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay,
                                               long repeat)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay,
                                               long repeat,
                                               java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay,
                                               long repeat,
                                               long repeats)

Specified by:

schedule in interface ITaskScheduler

schedule

public IScheduledTask<java.lang.Void> schedule(java.lang.Runnable runnable,
                                               long delay,
                                               long repeat,
                                               long repeats,
                                               java.util.concurrent.TimeUnit timeUnit)

Specified by:

schedule in interface ITaskScheduler

shutdown

public void shutdown()

Specified by:

shutdown in interface ITaskScheduler

execute

public void execute(@NotNull
                    @NotNull java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

offerTask

public <V> IScheduledTask<V> offerTask(IScheduledTask<V> scheduledTask)

Specified by:

offerTask in interface IScheduledTaskInvoker

cancelAll

public ITaskScheduler cancelAll()

Specified by:

cancelAll in interface IScheduledTaskInvoker