Class ConcurrentQueueObjectPool<O>

java.lang.Object

org.newsclub.net.unix.pool.ConcurrentQueueObjectPool<O>

Type Parameters:

O - The object type.

All Implemented Interfaces:

ObjectPool<O>

public final class ConcurrentQueueObjectPool<O>
extends Object
implements ObjectPool<O>

An ObjectPool implemented using ConcurrentLinkedQueue.

Author:

Christian Kohlschütter

Nested Class Summary

Nested classes/interfaces inherited from interface ObjectPool

ObjectPool.Lease<O>, ObjectPool.ObjectSanitizer<T>, ObjectPool.ObjectSupplier<T>

Modifier and Type	Interface	Description
static interface	ObjectPool.Lease<O>	A lease for an object (obtained via ObjectPool.Lease.get()); working with the object is only permitted before ObjectPool.Lease.close().
static interface	ObjectPool.ObjectSanitizer<T>	Sanitizes a previously leased object so it can be reused by the pool.
static interface	ObjectPool.ObjectSupplier<T>	Supplies a leased object.

Constructor Summary

Constructors

Constructor	Description
ConcurrentQueueObjectPool(ObjectPool.ObjectSupplier<@NonNull O> supplier, ObjectPool.ObjectSanitizer<@NonNull O> sanitizer, int maxCapacity)	Constructs a ConcurrentQueueObjectPool with the given capacity, supplier and sanitizer.

Method Summary

Modifier and Type	Method	Description
ObjectPool.Lease<O>	take()	Takes an exclusive lease of an object from the pool.

Methods inherited from class Object

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

Constructor Details

ConcurrentQueueObjectPool

public ConcurrentQueueObjectPool(ObjectPool.ObjectSupplier<@NonNull O> supplier,
 ObjectPool.ObjectSanitizer<@NonNull O> sanitizer,
 int maxCapacity)

Constructs a ConcurrentQueueObjectPool with the given capacity, supplier and sanitizer.

Parameters:

supplier - The supplier.

sanitizer - The sanitizer.

maxCapacity - The maximum capacity.

Method Details

take

public ObjectPool.Lease<O> take()

Description copied from interface: ObjectPool

Takes an exclusive lease of an object from the pool. If no existing object is available from the pool, a new one may be provided.

Specified by:

take in interface ObjectPool<O>

Returns:

The object.