Class ThreadPoolBudget

java.lang.Object

org.eclipse.jetty.util.thread.ThreadPoolBudget

@ManagedObject
public class ThreadPoolBudget
extends Object

A budget of required thread usage, used to warn or error for insufficient configured threads.

See Also:

• ThreadPool.SizedThreadPool.getThreadPoolBudget()

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ThreadPoolBudget.Lease
class	ThreadPoolBudget.Leased	An allocation of threads

Field Summary

Fields

Modifier and Type	Field	Description
private final Set<ThreadPoolBudget.Leased>	leases
private static final Logger	LOG
private static final ThreadPoolBudget.Lease	NOOP_LEASE
private final ThreadPool.SizedThreadPool	pool
private final int	warnAt
private final AtomicBoolean	warned

Constructor Summary

Constructors

Constructor	Description
ThreadPoolBudget(ThreadPool.SizedThreadPool pool)	Construct a budget for a SizedThreadPool.
ThreadPoolBudget(ThreadPool.SizedThreadPool pool, int warnAt)	Deprecated.

Method Summary

Modifier and Type	Method	Description
boolean	check(int maxThreads)	Checks leases against the given number of maxThreads.
int	getLeasedThreads()
ThreadPool.SizedThreadPool	getSizedThreadPool()
static ThreadPoolBudget.Lease	leaseFrom(Executor executor, Object leasee, int threads)
ThreadPoolBudget.Lease	leaseTo(Object leasee, int threads)
private void	printInfoOnLeases()
void	reset()

Methods inherited from class Object

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

Field Details

LOG

private static final Logger LOG

NOOP_LEASE

private static final ThreadPoolBudget.Lease NOOP_LEASE

leases

private final Set<ThreadPoolBudget.Leased> leases

warned

private final AtomicBoolean warned

pool

private final ThreadPool.SizedThreadPool pool

warnAt

private final int warnAt

Constructor Details

ThreadPoolBudget

public ThreadPoolBudget(ThreadPool.SizedThreadPool pool)

Construct a budget for a SizedThreadPool.

Parameters:

pool - The pool to budget thread allocation for.

ThreadPoolBudget

@Deprecated
public ThreadPoolBudget(ThreadPool.SizedThreadPool pool,
 int warnAt)

Deprecated.

Parameters:

pool - The pool to budget thread allocation for.

warnAt - The level of free threads at which a warning is generated.

Method Details

getSizedThreadPool

public ThreadPool.SizedThreadPool getSizedThreadPool()

getLeasedThreads

@ManagedAttribute("the number of threads leased to components")
public int getLeasedThreads()

reset

public void reset()

leaseTo

public ThreadPoolBudget.Lease leaseTo(Object leasee,
 int threads)

check

public boolean check(int maxThreads)
              throws IllegalStateException

Checks leases against the given number of maxThreads.

Parameters:

maxThreads - A proposed change to the maximum threads to check.

Returns:

true if passes check, false if otherwise (see logs for details)

Throws:

IllegalStateException - if insufficient threads are configured.

printInfoOnLeases

private void printInfoOnLeases()

leaseFrom

public static ThreadPoolBudget.Lease leaseFrom(Executor executor,
 Object leasee,
 int threads)