Package io.deephaven.base.pool

Class ThreadSafeLenientFixedSizePool<T>

java.lang.Object

io.deephaven.base.pool.ThreadSafeLenientFixedSizePool<T>

All Implemented Interfaces:

Pool<T>, Pool.MultiGiver<T>, Pool.MultiPool<T>, Pool.MultiTaker<T>, Pool.SinglePool<T>

Direct Known Subclasses:

DynamicDelayedLogEntryPoolImpl, DynamicLogBufferPoolImpl, DynamicLogEntryPoolImpl

public class ThreadSafeLenientFixedSizePool<T>
extends Object
implements Pool.MultiPool<T>

A pool that

• holds at least size items,
• creates size items in the pool immediately,
• creates a new item when the pool underflows,
• discards the item when the pool overflows,
• optionally clears the items given to it, and
• IS thread-safe

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.base.pool.Pool

Pool.Factory, Pool.MultiGiver<T>, Pool.MultiPool<T>, Pool.MultiTaker<T>, Pool.SinglePool<T>

Field Summary

Fields

Modifier and Type	Field	Description
static Pool.Factory	FACTORY
static final int	MIN_SIZE

Constructor Summary

Constructors

Constructor	Description
ThreadSafeLenientFixedSizePool(int size, Function<ThreadSafeLenientFixedSizePool<T>,T> factory, Consumer<? super T> clearingProcedure)
ThreadSafeLenientFixedSizePool(int size, Supplier<T> factory, Consumer<? super T> clearingProcedure)
ThreadSafeLenientFixedSizePool(String name, int size, Function<ThreadSafeLenientFixedSizePool<T>,T> factory, Consumer<? super T> clearingProcedure)
ThreadSafeLenientFixedSizePool(String name, int size, Supplier<T> factory, Consumer<? super T> clearingProcedure)

Method Summary

Modifier and Type	Method	Description
void	give(T item)	Gives an unused item back to the pool.
protected boolean	giveInternal(T item)
T	take()	Takes an item from the pool.
T	takeMaybeNull()

Methods inherited from class java.lang.Object

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

Field Details

FACTORY

public static Pool.Factory FACTORY

MIN_SIZE

public static final int MIN_SIZE

See Also:

• Constant Field Values

Constructor Details

ThreadSafeLenientFixedSizePool

public ThreadSafeLenientFixedSizePool(int size,
 Supplier<T> factory,
 Consumer<? super T> clearingProcedure)

ThreadSafeLenientFixedSizePool

public ThreadSafeLenientFixedSizePool(String name,
 int size,
 Supplier<T> factory,
 Consumer<? super T> clearingProcedure)

ThreadSafeLenientFixedSizePool

public ThreadSafeLenientFixedSizePool(int size,
 Function<ThreadSafeLenientFixedSizePool<T>,T> factory,
 Consumer<? super T> clearingProcedure)

ThreadSafeLenientFixedSizePool

public ThreadSafeLenientFixedSizePool(String name,
 int size,
 Function<ThreadSafeLenientFixedSizePool<T>,T> factory,
 Consumer<? super T> clearingProcedure)

Method Details

take

public T take()

Description copied from interface: Pool

Takes an item from the pool. Depending on pool policy, if there are no items available, this may block, create a new item, or throw a PoolEmptyException.

Specified by:

take in interface Pool<T>

give

public void give(T item)

Description copied from interface: Pool

Gives an unused item back to the pool. Passing null is safe and has no effect. If the pool has a clearing procedure, the item will be cleared. Depending on pool policy, if the pool is full, this may block, discard the item, or throw a PoolFullException.

Specified by:

give in interface Pool<T>

giveInternal

protected boolean giveInternal(T item)

takeMaybeNull

public T takeMaybeNull()