Class DelegatingThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.http.spi.DelegatingThreadPool

All Implemented Interfaces:

Executor, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, ThreadPool, TryExecutor, VirtualThreads.Configurable

public class DelegatingThreadPool
extends ContainerLifeCycle
implements ThreadPool, TryExecutor, VirtualThreads.Configurable

Nested Class Summary

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer, Dumpable.DumpAppendable

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Nested classes/interfaces inherited from interface ThreadPool

ThreadPool.SizedThreadPool

Nested classes/interfaces inherited from interface TryExecutor

TryExecutor.NoTryExecutor

Field Summary

Fields inherited from class AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

LEGEND

Fields inherited from interface TryExecutor

NO_TRY

Constructor Summary

Constructors

Constructor	Description
DelegatingThreadPool(Executor executor)

Method Summary

Modifier and Type	Method	Description
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
void	execute(Runnable job)
Executor	getExecutor()
int	getIdleThreads()
int	getThreads()
Executor	getVirtualThreadsExecutor()
boolean	isLowOnThreads()
void	join()	Blocks until the thread pool is stopped.
void	setExecutor(Executor executor)
void	setVirtualThreadsExecutor(Executor executor)
boolean	tryExecute(Runnable task)	Attempt to execute a task.

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, doStart, dump, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface Container

getCachedBeans, getEventListeners

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Methods inherited from interface VirtualThreads.Configurable

isUseVirtualThreads, setUseVirtualThreads

Constructor Details

DelegatingThreadPool

public DelegatingThreadPool(Executor executor)

Method Details

getExecutor

public Executor getExecutor()

setExecutor

public void setExecutor(Executor executor)

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

Specified by:

execute in interface TryExecutor

tryExecute

public boolean tryExecute(Runnable task)

Description copied from interface: TryExecutor

Attempt to execute a task.

Specified by:

tryExecute in interface TryExecutor

Parameters:

task - The task to be executed

Returns:

True IFF the task has been given directly to a thread to execute. The task cannot be queued pending the later availability of a Thread.

getVirtualThreadsExecutor

public Executor getVirtualThreadsExecutor()

Specified by:

getVirtualThreadsExecutor in interface VirtualThreads.Configurable

Returns:

the Executor to use to execute tasks in virtual threads

setVirtualThreadsExecutor

public void setVirtualThreadsExecutor(Executor executor)

Specified by:

setVirtualThreadsExecutor in interface VirtualThreads.Configurable

Parameters:

executor - the Executor to use to execute tasks in virtual threads

See Also:

• VirtualThreads.areSupported()

getIdleThreads

public int getIdleThreads()

Specified by:

getIdleThreads in interface ThreadPool

Returns:

The number of idle threads in the pool

getThreads

public int getThreads()

Specified by:

getThreads in interface ThreadPool

Returns:

The total number of threads currently in the pool

isLowOnThreads

public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface ThreadPool

Returns:

True if the pool is low on threads

join

public void join()
          throws InterruptedException

Description copied from interface: ThreadPool

Blocks until the thread pool is stopped.

Specified by:

join in interface ThreadPool

Throws:

InterruptedException - if thread was interrupted

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception - If there was a problem stopping. Will cause a transition to FAILED state