Package org.eclipse.jetty.util.thread

Class ScheduledExecutorScheduler

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.thread.ScheduledExecutorScheduler

All Implemented Interfaces:

Dumpable, LifeCycle, Scheduler

Direct Known Subclasses:

LowResourceMonitor.LRMScheduler

@ManagedObject
public class ScheduledExecutorScheduler
extends AbstractLifeCycle
implements Scheduler, Dumpable

Implementation of Scheduler based on JDK's ScheduledThreadPoolExecutor.

While use of ScheduledThreadPoolExecutor creates futures that will not be used, it has the advantage of allowing to set a property to remove cancelled tasks from its queue even if the task did not fire, which provides a huge benefit in the performance of garbage collection in young generation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ScheduledExecutorScheduler.ScheduledFutureTask

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Scheduler

Scheduler.Task

Field Summary

Fields

Modifier and Type	Field	Description
private final ClassLoader	classloader
private final AtomicInteger	count
private final boolean	daemon
private final String	name
private ScheduledThreadPoolExecutor	scheduler
private Thread	thread
private final ThreadGroup	threadGroup
private final int	threads

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
ScheduledExecutorScheduler()
ScheduledExecutorScheduler(String name, boolean daemon)
ScheduledExecutorScheduler(String name, boolean daemon, int threads)
ScheduledExecutorScheduler(String name, boolean daemon, ClassLoader classLoader)
ScheduledExecutorScheduler(String name, boolean daemon, ClassLoader classLoader, ThreadGroup threadGroup)
ScheduledExecutorScheduler(String name, boolean daemon, ClassLoader classLoader, ThreadGroup threadGroup, int threads)

Method Summary

Modifier and Type	Method	Description
protected void	doStart()
protected void	doStop()
String	dump()
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
String	getName()
int	getThreads()
boolean	isDaemon()
Scheduler.Task	schedule(Runnable task, long delay, TimeUnit unit)

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dumpSelf

Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle

addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Field Details

name

private final String name

daemon

private final boolean daemon

classloader

private final ClassLoader classloader

threadGroup

private final ThreadGroup threadGroup

threads

private final int threads

count

private final AtomicInteger count

scheduler

private volatile ScheduledThreadPoolExecutor scheduler

thread

private volatile Thread thread

Constructor Details

ScheduledExecutorScheduler

public ScheduledExecutorScheduler()

ScheduledExecutorScheduler

public ScheduledExecutorScheduler(String name,
 boolean daemon)

ScheduledExecutorScheduler

public ScheduledExecutorScheduler(@Name("name")
 String name,
 @Name("daemon")
 boolean daemon,
 @Name("threads")
 int threads)

ScheduledExecutorScheduler

public ScheduledExecutorScheduler(String name,
 boolean daemon,
 ClassLoader classLoader)

ScheduledExecutorScheduler

public ScheduledExecutorScheduler(String name,
 boolean daemon,
 ClassLoader classLoader,
 ThreadGroup threadGroup)

ScheduledExecutorScheduler

public ScheduledExecutorScheduler(@Name("name")
 String name,
 @Name("daemon")
 boolean daemon,
 @Name("classLoader")
 ClassLoader classLoader,
 @Name("threadGroup")
 ThreadGroup threadGroup,
 @Name("threads")
 int threads)

Parameters:

name - The name of the scheduler threads or null for automatic name

daemon - True if scheduler threads should be daemon

classLoader - The classloader to run the threads with or null to use the current thread context classloader

threadGroup - The threadgroup to use or null for no thread group

threads - The number of threads to pass to the the core ScheduledThreadPoolExecutor or -1 for a heuristic determined number of threads.

Method Details

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class AbstractLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class AbstractLifeCycle

Throws:

Exception

schedule

public Scheduler.Task schedule(Runnable task,
 long delay,
 TimeUnit unit)

Specified by:

schedule in interface Scheduler

dump

public String dump()

Specified by:

dump in interface Dumpable

dump

public void dump(Appendable out,
 String indent)
          throws IOException

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable

getName

@ManagedAttribute("The name of the scheduler")
public String getName()

isDaemon

@ManagedAttribute("Whether the scheduler uses daemon threads")
public boolean isDaemon()

getThreads

@ManagedAttribute("The number of scheduler threads")
public int getThreads()