Modifier and Type	Class and Description
public static class	ConcurrentPool.ConcurrentEntry<E> A Pool entry that holds metadata and a pooled object.
private static class	ConcurrentPool.Holder<P> Holds a strong and a weak reference to an `Entry` to avoid holding on to entries that are not released, so that they can be garbage collected.
public static enum	ConcurrentPool.StrategyType The type of the strategy to use for the pool.

Modifier and Type	Field and Description
private final List<ConcurrentPool.Holder<P>>	entries
private final LongAdder	leaked
private final AutoLock	lock
private static final Logger	LOG
private final ToIntFunction<P>	maxMultiplex
private final int	maxSize
private final AtomicInteger	nextIndex
public static final int	OPTIMAL_MAX_SIZE `ConcurrentPool` internally needs to linearly scan a list to perform an acquisition.
private final ConcurrentPool.StrategyType	strategyType
private volatile boolean	terminated

Access	Constructor and Description
public	ConcurrentPool(ConcurrentPool.StrategyType the strategy to used to lookup entries strategyType, int the maximum number of pooled entries maxSize) Creates an instance with the specified strategy.
public	ConcurrentPool(ConcurrentPool.StrategyType the strategy to used to lookup entries strategyType, int the maximum number of pooled entries maxSize, boolean whether a `ThreadLocal` cache should be used for the most recently released entry cache) Deprecated cache is no longer supported. Use `StrategyType#THREAD_ID` Creates an instance with the specified strategy.
public	ConcurrentPool(ConcurrentPool.StrategyType the strategy to used to lookup entries strategyType, int the maximum number of pooled entries maxSize, boolean whether a `ThreadLocal` cache should be used for the most recently released entry cache, ToIntFunction<P> a function that given the pooled object returns the max multiplex count maxMultiplex) Deprecated cache is no longer supported. Use `StrategyType#THREAD_ID` Creates an instance with the specified strategy.
public	ConcurrentPool(ConcurrentPool.StrategyType the strategy to used to lookup entries strategyType, int the maximum number of pooled entries maxSize, ToIntFunction<P> a function that given the pooled object returns the max multiplex count maxMultiplex) Creates an instance with the specified strategy.

Method Summary

Modifier and Type	Method and Description
public Pool.Entry<P>	acquire() Implements org.eclipse.jetty.util.Pool.acquire. Acquires an entry from the pool.
public void	dump(Appendable The appendable to dump to out, String The indent to apply after any new lines. indent) Implements org.eclipse.jetty.util.component.Dumpable.dump. Dump this object (and children) into an Appendable using the provided indent after any new lines.
public long	getLeaked()
private int	Returns: the max multiplex count for the given pooled object getMaxMultiplex(P the pooled object pooled) Retrieves the max multiplex count for the given pooled object.
public int	getMaxSize() Implements org.eclipse.jetty.util.Pool.getMaxSize.
public boolean	isTerminated() Implements org.eclipse.jetty.util.Pool.isTerminated.
private void	leaked(ConcurrentPool.Holder<P> holder)
private boolean	release(Pool.Entry<P> entry)
private boolean	remove(Pool.Entry<P> entry)
public Pool.Entry<P>	reserve() Implements org.eclipse.jetty.util.Pool.reserve. Creates a new disabled slot into the pool.
public int	size() Implements org.eclipse.jetty.util.Pool.size.
private int	startIndex(int size)
public Stream<Pool.Entry<P>>	stream() Implements org.eclipse.jetty.util.Pool.stream.
pack-priv void	sweep()
public Collection<Pool.Entry<P>>	terminate() Implements org.eclipse.jetty.util.Pool.terminate. Terminates this `Pool`.
private boolean	terminate(Pool.Entry<P> entry)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

entries	back to summary
private final List<ConcurrentPool.Holder<P>> entries

leaked	back to summary
private final LongAdder leaked

lock	back to summary
private final AutoLock lock

LOG	back to summary
private static final Logger LOG

maxMultiplex	back to summary
private final ToIntFunction<P> maxMultiplex

maxSize	back to summary
private final int maxSize

nextIndex	back to summary
private final AtomicInteger nextIndex

OPTIMAL_MAX_SIZE	back to summary
public static final int OPTIMAL_MAX_SIZE `ConcurrentPool` internally needs to linearly scan a list to perform an acquisition. This list needs to be reasonably short otherwise there is a risk that scanning the list becomes a bottleneck. Instances created with a size at most this value should be immune to this problem.

strategyType	back to summary
private final ConcurrentPool.StrategyType strategyType

terminated	back to summary
private volatile boolean terminated

Constructor Detail

ConcurrentPool	back to summary
public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize) Creates an instance with the specified strategy. Parameters strategyType:ConcurrentPool.StrategyType the strategy to used to lookup entries maxSize:int the maximum number of pooled entries

ConcurrentPool

back to summary

public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize)

Creates an instance with the specified strategy.

Parameters

strategyType:ConcurrentPool.StrategyType: the strategy to used to lookup entries
maxSize:int: the maximum number of pooled entries

ConcurrentPool back to summary

ConcurrentPool	back to summary
public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, boolean cache) Deprecated cache is no longer supported. Use `StrategyType#THREAD_ID` Creates an instance with the specified strategy. Parameters strategyType:ConcurrentPool.StrategyType the strategy to used to lookup entries maxSize:int the maximum number of pooled entries cache:boolean whether a `ThreadLocal` cache should be used for the most recently released entry Annotations @Deprecated

public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, boolean cache)

Deprecated

cache is no longer supported. Use StrategyType#THREAD_ID

Creates an instance with the specified strategy.

Parameters

strategyType:ConcurrentPool.StrategyType: the strategy to used to lookup entries
maxSize:int: the maximum number of pooled entries
cache:boolean: whether a ThreadLocal cache should be used for the most recently released entry

Annotations

@Deprecated

ConcurrentPool back to summary

ConcurrentPool	back to summary
public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, boolean cache, ToIntFunction<P> maxMultiplex) Deprecated cache is no longer supported. Use `StrategyType#THREAD_ID` Creates an instance with the specified strategy. and a function that returns the max multiplex count for a given pooled object. Parameters strategyType:ConcurrentPool.StrategyType the strategy to used to lookup entries maxSize:int the maximum number of pooled entries cache:boolean whether a `ThreadLocal` cache should be used for the most recently released entry maxMultiplex:ToIntFunction<P> a function that given the pooled object returns the max multiplex count Annotations @Deprecated

public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, boolean cache, ToIntFunction maxMultiplex)

Deprecated

cache is no longer supported. Use StrategyType#THREAD_ID

Creates an instance with the specified strategy. and a function that returns the max multiplex count for a given pooled object.

Parameters

strategyType:ConcurrentPool.StrategyType: the strategy to used to lookup entries
maxSize:int: the maximum number of pooled entries
cache:boolean: whether a ThreadLocal cache should be used for the most recently released entry
maxMultiplex:ToIntFunction: a function that given the pooled object returns the max multiplex count

Annotations

@Deprecated

ConcurrentPool	back to summary
public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, ToIntFunction<P> maxMultiplex) Creates an instance with the specified strategy. and a function that returns the max multiplex count for a given pooled object. Parameters strategyType:ConcurrentPool.StrategyType the strategy to used to lookup entries maxSize:int the maximum number of pooled entries maxMultiplex:ToIntFunction<P> a function that given the pooled object returns the max multiplex count

ConcurrentPool

back to summary

public ConcurrentPool(ConcurrentPool.StrategyType strategyType, int maxSize, ToIntFunction maxMultiplex)

Creates an instance with the specified strategy. and a function that returns the max multiplex count for a given pooled object.

Parameters

strategyType:ConcurrentPool.StrategyType: the strategy to used to lookup entries
maxSize:int: the maximum number of pooled entries
maxMultiplex:ToIntFunction: a function that given the pooled object returns the max multiplex count

Method Detail

acquire back to summary

acquire	back to summary
public Pool.Entry<P> acquire() Implements org.eclipse.jetty.util.Pool.acquire. Doc from org.eclipse.jetty.util.Pool.acquire. Acquires an entry from the pool. Only enabled entries will be returned from this method and their `Entry#enable(Object, boolean)` method must not be called. Returns:Pool.Entry<P> an entry from the pool or null if none is available. Annotations @Override

public Pool.Entry acquire()

Implements org.eclipse.jetty.util.Pool.acquire.

Doc from org.eclipse.jetty.util.Pool.acquire.

Acquires an entry from the pool.

Only enabled entries will be returned from this method and their Entry#enable(Object, boolean) method must not be called.

Returns:Pool.Entry

an entry from the pool or null if none is available.

Annotations

@Override

dump	back to summary
public void dump(Appendable out, String indent) throws IOException Implements org.eclipse.jetty.util.component.Dumpable.dump. Doc from org.eclipse.jetty.util.component.Dumpable.dump. 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. Parameters out:Appendable The appendable to dump to indent:String The indent to apply after any new lines. Annotations @Override Exceptions IOException: if unable to write to Appendable

dump

back to summary

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

Implements org.eclipse.jetty.util.component.Dumpable.dump.

Doc from org.eclipse.jetty.util.component.Dumpable.dump.

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.

Parameters

out:Appendable: The appendable to dump to
indent:String: The indent to apply after any new lines.

Annotations

@Override

Exceptions

IOException:: if unable to write to Appendable

getLeaked	back to summary
public long getLeaked() Annotations @ManagedAttribute:number of entries leaked (not released nor referenced)

getMaxMultiplex	back to summary
private int getMaxMultiplex(P pooled) Retrieves the max multiplex count for the given pooled object. Parameters pooled:P the pooled object Returns:int the max multiplex count for the given pooled object

getMaxMultiplex

back to summary

private int getMaxMultiplex(P pooled)

Retrieves the max multiplex count for the given pooled object.

Parameters

pooled:P: the pooled object

Returns:int

the max multiplex count for the given pooled object

getMaxSize back to summary

getMaxSize	back to summary
public int getMaxSize() Implements org.eclipse.jetty.util.Pool.getMaxSize. Returns:int Doc from org.eclipse.jetty.util.Pool.getMaxSize. the maximum number of entries in this `Pool` Annotations @Override

public int getMaxSize()

Implements org.eclipse.jetty.util.Pool.getMaxSize.

Returns:int

Doc from org.eclipse.jetty.util.Pool.getMaxSize.

the maximum number of entries in this Pool

Annotations

@Override

isTerminated back to summary

isTerminated	back to summary
public boolean isTerminated() Implements org.eclipse.jetty.util.Pool.isTerminated. Returns:boolean Doc from org.eclipse.jetty.util.Pool.isTerminated. whether this `Pool` has been terminated Annotations @Override

public boolean isTerminated()

Implements org.eclipse.jetty.util.Pool.isTerminated.

Returns:boolean

Doc from org.eclipse.jetty.util.Pool.isTerminated.

whether this Pool has been terminated

Annotations

@Override

leaked	back to summary
private void leaked(ConcurrentPool.Holder<P> holder)

release	back to summary
private boolean release(Pool.Entry<P> entry)

remove	back to summary
private boolean remove(Pool.Entry<P> entry)

reserve back to summary

reserve	back to summary
public Pool.Entry<P> reserve() Implements org.eclipse.jetty.util.Pool.reserve. Doc from org.eclipse.jetty.util.Pool.reserve. Creates a new disabled slot into the pool. The returned entry must ultimately have the `Entry#enable(Object, boolean)` method called or be removed via `Pool.Entry#remove()`. Returns:Pool.Entry<P> a disabled entry that is contained in the pool, or `null` if the pool is terminated or if the pool cannot reserve an entry Annotations @Override

public Pool.Entry reserve()

Implements org.eclipse.jetty.util.Pool.reserve.

Doc from org.eclipse.jetty.util.Pool.reserve.

Creates a new disabled slot into the pool.

The returned entry must ultimately have the Entry#enable(Object, boolean) method called or be removed via Pool.Entry#remove().

Returns:Pool.Entry

a disabled entry that is contained in the pool, or null if the pool is terminated or if the pool cannot reserve an entry

Annotations

@Override

size back to summary

size	back to summary
public int size() Implements org.eclipse.jetty.util.Pool.size. Returns:int Doc from org.eclipse.jetty.util.Pool.size. the current number of entries in this `Pool` Annotations @Override

public int size()

Implements org.eclipse.jetty.util.Pool.size.

Returns:int

Doc from org.eclipse.jetty.util.Pool.size.

the current number of entries in this Pool

Annotations

@Override

startIndex	back to summary
private int startIndex(int size)

stream back to summary

stream	back to summary
public Stream<Pool.Entry<P>> stream() Implements org.eclipse.jetty.util.Pool.stream. Returns:Stream<Pool.Entry<P>> Doc from org.eclipse.jetty.util.Pool.stream. a `Stream` over the entries Annotations @Override

public Stream<Pool.Entry> stream()

Implements org.eclipse.jetty.util.Pool.stream.

Returns:Stream<Pool.Entry>

Doc from org.eclipse.jetty.util.Pool.stream.

a Stream over the entries

Annotations

@Override

sweep	back to summary
pack-priv void sweep()

terminate back to summary

terminate	back to summary
public Collection<Pool.Entry<P>> terminate() Implements org.eclipse.jetty.util.Pool.terminate. Doc from org.eclipse.jetty.util.Pool.terminate. Terminates this `Pool`. All the entries are marked as terminated and cannot be acquired nor released, but only removed. The returned list of all entries may be iterated to perform additional operations on the pooled objects. The pool cannot be used anymore after it is terminated. Returns:Collection<Pool.Entry<P>> a list of all entries Annotations @Override

public Collection<Pool.Entry> terminate()

Implements org.eclipse.jetty.util.Pool.terminate.

Doc from org.eclipse.jetty.util.Pool.terminate.

Terminates this Pool.

All the entries are marked as terminated and cannot be acquired nor released, but only removed.

The returned list of all entries may be iterated to perform additional operations on the pooled objects.

The pool cannot be used anymore after it is terminated.

Returns:Collection<Pool.Entry>

a list of all entries

Annotations

@Override

terminate	back to summary
private boolean terminate(Pool.Entry<P> entry)

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

org.eclipse.jetty.util back to summary

public Class ConcurrentPool.ConcurrentEntry<E>

Class Inheritance

extends Object
implements Pool.Entry<E>

java.lang.Object
org.eclipse.jetty.util.ConcurrentPool.ConcurrentEntry

All Implemented Interfaces

org.eclipse.jetty.util.Pool.Entry

A Pool entry that holds metadata and a pooled object.

Field Summary

Modifier and Type	Field and Description
private final ConcurrentPool.Holder<E>	holder
private final ConcurrentPool<E>	pool
private E	pooled
private final AtomicBiInteger	state

Constructor Summary

Access	Constructor and Description
public	ConcurrentEntry(ConcurrentPool<E> pool)

Method Summary

Modifier and Type	Method and Description
public boolean	enable(E the pooled object for this `Entry` pooled, boolean whether this `Entry` should be atomically enabled and acquired acquire) Implements org.eclipse.jetty.util.Pool.Entry.enable. Enables this, previously `reserved`, `Entry`.
private ConcurrentPool.Holder<E>	getHolder()
public E	getPooled() Implements org.eclipse.jetty.util.Pool.Entry.getPooled.
public boolean	isIdle() Implements org.eclipse.jetty.util.Pool.Entry.isIdle.
public boolean	isInUse() Implements org.eclipse.jetty.util.Pool.Entry.isInUse.
public boolean	isReserved() Implements org.eclipse.jetty.util.Pool.Entry.isReserved.
public boolean	isTerminated() Implements org.eclipse.jetty.util.Pool.Entry.isTerminated.
public boolean	release() Implements org.eclipse.jetty.util.Pool.Entry.release. Releases this `Entry` to the `Pool`.
public boolean	remove() Implements org.eclipse.jetty.util.Pool.Entry.remove. Removes this `Entry` from the `Pool`.
private boolean	terminate()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private boolean	Returns: whether this `Entry` was acquired tryAcquire() Tries to acquire this `Entry`.
private boolean	Returns: whether this `Entry` was enabled tryEnable(boolean whether to also acquire this `Entry` acquire) Tries to enable, and possible also acquire, this `Entry`.
private boolean	Returns: true if this `Entry` was released, false if `tryRemove()` should be called. tryRelease() Tries to release this `Entry`.
private boolean	Returns: whether this `Entry` can be removed tryRemove() Tries to remove this `Entry` by marking it as terminated.
private boolean	tryTerminate()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

holder	back to summary
private final ConcurrentPool.Holder<E> holder

pool	back to summary
private final ConcurrentPool<E> pool

pooled	back to summary
private E pooled

state	back to summary
private final AtomicBiInteger state

Constructor Detail

ConcurrentEntry	back to summary
public ConcurrentEntry(ConcurrentPool<E> pool)

Method Detail

enable back to summary

enable	back to summary
public boolean enable(E pooled, boolean acquire) Implements org.eclipse.jetty.util.Pool.Entry.enable. Doc from org.eclipse.jetty.util.Pool.Entry.enable. Enables this, previously `reserved`, `Entry`. An entry returned from the `reserve()` method must be enabled with this method, once and only once, before it is usable by the pool. The entry may be enabled and not acquired, in which case it is immediately available to be acquired, potentially by another thread; or it can be enabled and acquired atomically so that no other thread can acquire it, although the acquire may still fail if the pool has been terminated. Parameters pooled:E the pooled object for this `Entry` acquire:boolean whether this `Entry` should be atomically enabled and acquired Returns:boolean whether this `Entry` was enabled Annotations @Override

public boolean enable(E pooled, boolean acquire)

Implements org.eclipse.jetty.util.Pool.Entry.enable.

Doc from org.eclipse.jetty.util.Pool.Entry.enable.

Enables this, previously reserved, Entry.

An entry returned from the reserve() method must be enabled with this method, once and only once, before it is usable by the pool.

The entry may be enabled and not acquired, in which case it is immediately available to be acquired, potentially by another thread; or it can be enabled and acquired atomically so that no other thread can acquire it, although the acquire may still fail if the pool has been terminated.

Parameters

pooled:E: the pooled object for this Entry
acquire:boolean: whether this Entry should be atomically enabled and acquired

Returns:boolean

whether this Entry was enabled

Annotations

@Override

getHolder	back to summary
private ConcurrentPool.Holder<E> getHolder()

getPooled	back to summary
public E getPooled() Implements org.eclipse.jetty.util.Pool.Entry.getPooled. Returns:E Doc from org.eclipse.jetty.util.Pool.Entry.getPooled. the pooled object Annotations @Override

getPooled

back to summary

public E getPooled()

Implements org.eclipse.jetty.util.Pool.Entry.getPooled.

Returns:E

Doc from org.eclipse.jetty.util.Pool.Entry.getPooled.

the pooled object

Annotations

@Override

isIdle back to summary

isIdle	back to summary
public boolean isIdle() Implements org.eclipse.jetty.util.Pool.Entry.isIdle. Returns:boolean Doc from org.eclipse.jetty.util.Pool.Entry.isIdle. whether this `Entry` is idle in the `Pool` Annotations @Override

public boolean isIdle()

Implements org.eclipse.jetty.util.Pool.Entry.isIdle.

Returns:boolean

Doc from org.eclipse.jetty.util.Pool.Entry.isIdle.

whether this Entry is idle in the Pool

Annotations

@Override

isInUse back to summary

isInUse	back to summary
public boolean isInUse() Implements org.eclipse.jetty.util.Pool.Entry.isInUse. Returns:boolean Doc from org.eclipse.jetty.util.Pool.Entry.isInUse. whether this `Entry` is in use Annotations @Override

public boolean isInUse()

Implements org.eclipse.jetty.util.Pool.Entry.isInUse.

Returns:boolean

Doc from org.eclipse.jetty.util.Pool.Entry.isInUse.

whether this Entry is in use

Annotations

@Override

isReserved back to summary

isReserved	back to summary
public boolean isReserved() Implements org.eclipse.jetty.util.Pool.Entry.isReserved. Returns:boolean Doc from org.eclipse.jetty.util.Pool.Entry.isReserved. whether this `Entry` is reserved Annotations @Override

public boolean isReserved()

Implements org.eclipse.jetty.util.Pool.Entry.isReserved.

Returns:boolean

Doc from org.eclipse.jetty.util.Pool.Entry.isReserved.

whether this Entry is reserved

Annotations

@Override

isTerminated back to summary

isTerminated	back to summary
public boolean isTerminated() Implements org.eclipse.jetty.util.Pool.Entry.isTerminated. Returns:boolean Doc from org.eclipse.jetty.util.Pool.Entry.isTerminated. whether this `Entry` is terminated Annotations @Override

public boolean isTerminated()

Implements org.eclipse.jetty.util.Pool.Entry.isTerminated.

Returns:boolean

Doc from org.eclipse.jetty.util.Pool.Entry.isTerminated.

whether this Entry is terminated

Annotations

@Override

release back to summary

public boolean release()

Implements org.eclipse.jetty.util.Pool.Entry.release.

Doc from org.eclipse.jetty.util.Pool.Entry.release.

Releases this Entry to the Pool.

Returns:boolean

whether this Entry was released

Annotations

@Override

remove back to summary

public boolean remove()

Implements org.eclipse.jetty.util.Pool.Entry.remove.

Doc from org.eclipse.jetty.util.Pool.Entry.remove.

Removes this Entry from the Pool.

Returns:boolean

whether this Entry was removed

Annotations

@Override

terminate	back to summary
private boolean terminate()

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

tryAcquire back to summary

private boolean tryAcquire()

Tries to acquire this Entry.

Returns:boolean: whether this Entry was acquired

tryEnable back to summary

private boolean tryEnable(boolean acquire)

Tries to enable, and possible also acquire, this Entry.

Parameters

acquire:boolean: whether to also acquire this Entry

Returns:boolean

whether this Entry was enabled

tryRelease back to summary

private boolean tryRelease()

Tries to release this Entry.

Returns:boolean: true if this Entry was released, false if tryRemove() should be called.

tryRemove back to summary

private boolean tryRemove()

Tries to remove this Entry by marking it as terminated.

Returns:boolean: whether this Entry can be removed

tryTerminate	back to summary
private boolean tryTerminate()

org.eclipse.jetty.util back to summary

private Class ConcurrentPool.Holder

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.util.ConcurrentPool.Holder

Holds a strong and a weak reference to an Entry to avoid holding on to entries that are not released, so that they can be garbage collected.

Methods released() and acquired() work together to clear the strong reference when the entry is acquired, and assign it when the entry is released.

This class handles a race condition happening when an entry is being released with multiplex count going 1 -> 0 by one thread that has not yet called released(), and immediately acquired by another thread that is calling acquired(). The call to acquired() spin loops until released() returns.

Field Summary

Modifier and Type	Field and Description
private volatile ConcurrentPool.ConcurrentEntry<P>	_strong
private final WeakReference<ConcurrentPool.ConcurrentEntry<P>>	_weak

Constructor Summary

Access	Constructor and Description
protected	Holder(ConcurrentPool.ConcurrentEntry<P> entry)

Method Summary

Modifier and Type	Method and Description
public void	acquired() Called when an entry is acquired from the pool with multiplex count going from `0` to `1`.
public Pool.Entry<P>	getEntry()
public void	released() Called when an entry is released to the pool with multiplex count going from `1` to `0`.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

_strong	back to summary
private volatile ConcurrentPool.ConcurrentEntry<P> _strong

_weak	back to summary
private final WeakReference<ConcurrentPool.ConcurrentEntry<P>> _weak

Constructor Detail

Holder	back to summary
protected Holder(ConcurrentPool.ConcurrentEntry<P> entry)

Method Detail

acquired	back to summary
public void acquired() Called when an entry is acquired from the pool with multiplex count going from `0` to `1`.

getEntry	back to summary
public Pool.Entry<P> getEntry()

released	back to summary
public void released() Called when an entry is released to the pool with multiplex count going from `1` to `0`.

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

org.eclipse.jetty.util back to summary

public final Enum ConcurrentPool.StrategyType

Class Inheritance

extends Enum<ConcurrentPool.StrategyType>

java.lang.Object
java.lang.Enum
org.eclipse.jetty.util.ConcurrentPool.StrategyType

The type of the strategy to use for the pool. The strategy primarily determines where iteration over the pool entries begins.

Field Summary

Modifier and Type	Field and Description
public static final ConcurrentPool.StrategyType	FIRST A strategy that looks for an entry always starting from the first entry.
public static final ConcurrentPool.StrategyType	RANDOM A strategy that looks for an entry by iterating from a random starting index.
public static final ConcurrentPool.StrategyType	ROUND_ROBIN A strategy that looks for an entry by iterating from a starting point that is incremented on every search.
public static final ConcurrentPool.StrategyType	THREAD_ID A strategy that uses the `Thread#getId()` of the current thread to select a starting point for an entry search.

Constructor Summary

Access	Constructor and Description
private	StrategyType()

Method Summary

Modifier and Type	Method and Description
public static ConcurrentPool.StrategyType	valueOf(String name)
public static ConcurrentPool.StrategyType[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

FIRST	back to summary
public static final ConcurrentPool.StrategyType FIRST A strategy that looks for an entry always starting from the first entry. It will favour the early entries in the pool, but may contend on them more.

RANDOM	back to summary
public static final ConcurrentPool.StrategyType RANDOM A strategy that looks for an entry by iterating from a random starting index. No entries are favoured and contention is reduced.

ROUND_ROBIN	back to summary
public static final ConcurrentPool.StrategyType ROUND_ROBIN A strategy that looks for an entry by iterating from a starting point that is incremented on every search. This gives similar results to the random strategy but with more predictable behaviour. No entries are favoured and contention is reduced.

THREAD_ID	back to summary
public static final ConcurrentPool.StrategyType THREAD_ID A strategy that uses the `Thread#getId()` of the current thread to select a starting point for an entry search. No entries are favoured and contention is reduced.

Constructor Detail

StrategyType	back to summary
private StrategyType()

Method Detail

valueOf	back to summary
public static ConcurrentPool.StrategyType valueOf(String name)

values	back to summary
public static ConcurrentPool.StrategyType[] values()

public Class ConcurrentPool<P>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class ConcurrentPool.ConcurrentEntry<E>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ConcurrentPool.Holder<P>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Enum ConcurrentPool.StrategyType

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail