Package io.activej.common.concurrent

Class ObjectPool<T>

java.lang.Object

io.activej.common.concurrent.ObjectPool<T>

public final class ObjectPool<T>
extends Object

Optimized lock-free concurrent object pool implementation

Constructor Summary

Constructors

Constructor	Description
ObjectPool()
ObjectPool(int initialCapacity)
ObjectPool(int initialCapacity, @Nullable Supplier<T> supplier)
ObjectPool(@Nullable Supplier<T> supplier)

Method Summary

Modifier and Type	Method	Description
int	capacity()
void	clear()
T	ensure()
T	ensure(Supplier<T> supplier)
boolean	isEmpty()
void	offer(T item)
T	poll()
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectPool

public ObjectPool()

ObjectPool

public ObjectPool(int initialCapacity)

ObjectPool

public ObjectPool(@Nullable
 @Nullable Supplier<T> supplier)

ObjectPool

public ObjectPool(int initialCapacity,
 @Nullable
 @Nullable Supplier<T> supplier)

Method Details

poll

public T poll()

ensure

public T ensure()

ensure

public T ensure(Supplier<T> supplier)

offer

public void offer(T item)

clear

public void clear()

isEmpty

public boolean isEmpty()

size

public int size()

capacity

public int capacity()

toString

public String toString()

Overrides:

toString in class Object