Package org.eclipse.jetty.util.thread
Class ScheduledExecutorScheduler
java.lang.Object
org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.thread.ScheduledExecutorScheduler
- 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 ClassesModifier and TypeClassDescriptionprivate static class
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
FieldsModifier and TypeFieldDescriptionprivate final ClassLoader
private final AtomicInteger
private final boolean
private final String
private ScheduledThreadPoolExecutor
private Thread
private final ThreadGroup
private final int
-
Constructor Summary
ConstructorsConstructorDescriptionScheduledExecutorScheduler
(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
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.LifeCycle
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
-
Field Details
-
name
-
daemon
private final boolean daemon -
classloader
-
threadGroup
-
threads
private final int threads -
count
-
scheduler
-
thread
-
-
Constructor Details
-
ScheduledExecutorScheduler
public ScheduledExecutorScheduler() -
ScheduledExecutorScheduler
-
ScheduledExecutorScheduler
-
ScheduledExecutorScheduler
-
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 namedaemon
- True if scheduler threads should be daemonclassLoader
- The classloader to run the threads with or null to use the current thread context classloaderthreadGroup
- The threadgroup to use or null for no thread groupthreads
- The number of threads to pass to the the coreScheduledThreadPoolExecutor
or -1 for a heuristic determined number of threads.
-
-
Method Details
-
doStart
- Overrides:
doStart
in classAbstractLifeCycle
- Throws:
Exception
-
doStop
- Overrides:
doStop
in classAbstractLifeCycle
- Throws:
Exception
-
schedule
-
dump
-
dump
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 interfaceDumpable
- Parameters:
out
- The appendable to dump toindent
- The indent to apply after any new lines.- Throws:
IOException
- if unable to write to Appendable
-
getName
-
isDaemon
-
getThreads
-