模块 org.redkale

程序包 org.redkale.util

类 ObjectPool<T>

java.lang.Object

org.redkale.util.ObjectPool<T>

类型参数:

T - 对象池元素的数据类型

所有已实现的接口:

Consumer<T>, Supplier<T>

直接已知子类:

ByteBufferPool

public class ObjectPool<T>
extends Object
implements Supplier<T>, Consumer<T>

对象池

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

修饰符和类型	字段	说明
protected LongAdder	creatCounter
protected Creator<T>	creator
protected LongAdder	cycleCounter
protected boolean	debug
protected static Logger	logger
protected int	max
protected ObjectPool<T>	parent
protected Consumer<T>	prepare
protected Queue<T>	queue
protected Predicate<T>	recycler
protected boolean	safeCombine
protected boolean	unsafeDequeable
protected Thread	unsafeThread

构造器概要

构造器

限定符	构造器	说明
protected	ObjectPool(ObjectPool<T> parent, LongAdder creatCounter, LongAdder cycleCounter, Thread unsafeThread, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler, Queue<T> queue)

方法概要

修饰符和类型	方法	说明
void	accept(T e)
static <T> ObjectPool<T>	createSafePool(int max, Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(LongAdder creatCounter, LongAdder cycleCounter, int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(LongAdder creatCounter, LongAdder cycleCounter, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createSafePool(Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(int max, Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(Thread unsafeThread, int max, ObjectPool<T> safePool)
static <T> ObjectPool<T>	createUnsafePool(LongAdder creatCounter, LongAdder cycleCounter, int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(LongAdder creatCounter, LongAdder cycleCounter, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, int max, Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, Class<T> clazz, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, LongAdder creatCounter, LongAdder cycleCounter, int max, Supplier<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, LongAdder creatCounter, LongAdder cycleCounter, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, LongAdder creatCounter, LongAdder cycleCounter, Thread unsafeThread, int max, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
static <T> ObjectPool<T>	createUnsafePool(ObjectPool<T> parent, Creator<T> creator, Consumer<T> prepare, Predicate<T> recycler)
T	get()
long	getCreatCount()
LongAdder	getCreatCounter()
Creator<T>	getCreator()
long	getCycleCount()
LongAdder	getCycleCounter()
int	getMax()
Consumer<T>	getPrepare()
Predicate<T>	getRecycler()
void	setCreator(Creator<T> creator)

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.util.function.Consumer

andThen

字段详细资料

logger

protected static final Logger logger

debug

protected final boolean debug

creator

protected Creator<T> creator

max

protected int max

prepare

protected final Consumer<T> prepare

recycler

protected final Predicate<T> recycler

creatCounter

protected final LongAdder creatCounter

cycleCounter

protected final LongAdder cycleCounter

queue

protected final Queue<T> queue

unsafeDequeable

protected final boolean unsafeDequeable

parent

protected final ObjectPool<T> parent

unsafeThread

protected Thread unsafeThread

safeCombine

protected final boolean safeCombine

构造器详细资料

ObjectPool

protected ObjectPool(ObjectPool<T> parent,
                     LongAdder creatCounter,
                     LongAdder cycleCounter,
                     Thread unsafeThread,
                     int max,
                     Creator<T> creator,
                     Consumer<T> prepare,
                     Predicate<T> recycler,
                     Queue<T> queue)

方法详细资料

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(Class<T> clazz,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(int max,
                                                 Class<T> clazz,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(int max,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(int max,
                                                 Supplier<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(LongAdder creatCounter,
                                                 LongAdder cycleCounter,
                                                 int max,
                                                 Supplier<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(LongAdder creatCounter,
                                                 LongAdder cycleCounter,
                                                 int max,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 Class<T> clazz,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 int max,
                                                 Class<T> clazz,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 int max,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 int max,
                                                 Supplier<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 LongAdder creatCounter,
                                                 LongAdder cycleCounter,
                                                 int max,
                                                 Supplier<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 LongAdder creatCounter,
                                                 LongAdder cycleCounter,
                                                 int max,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(ObjectPool<T> parent,
                                                 LongAdder creatCounter,
                                                 LongAdder cycleCounter,
                                                 Thread unsafeThread,
                                                 int max,
                                                 Creator<T> creator,
                                                 Consumer<T> prepare,
                                                 Predicate<T> recycler)

createUnsafePool

public static <T> ObjectPool<T> createUnsafePool(Thread unsafeThread,
                                                 int max,
                                                 ObjectPool<T> safePool)

createSafePool

public static <T> ObjectPool<T> createSafePool(Class<T> clazz,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(int max,
                                               Class<T> clazz,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(Creator<T> creator,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(int max,
                                               Creator<T> creator,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(int max,
                                               Supplier<T> creator,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(LongAdder creatCounter,
                                               LongAdder cycleCounter,
                                               int max,
                                               Supplier<T> creator,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

createSafePool

public static <T> ObjectPool<T> createSafePool(LongAdder creatCounter,
                                               LongAdder cycleCounter,
                                               int max,
                                               Creator<T> creator,
                                               Consumer<T> prepare,
                                               Predicate<T> recycler)

setCreator

public void setCreator(Creator<T> creator)

getCreator

public Creator<T> getCreator()

getMax

public int getMax()

getPrepare

public Consumer<T> getPrepare()

getRecycler

public Predicate<T> getRecycler()

getCreatCounter

public LongAdder getCreatCounter()

getCycleCounter

public LongAdder getCycleCounter()

get

public T get()

指定者:

get 在接口中 Supplier<T>

accept

public void accept(T e)

指定者:

accept 在接口中 Consumer<T>

getCreatCount

public long getCreatCount()

getCycleCount

public long getCycleCount()