Package io.netty.util
Class Recycler.LocalPool<T>
java.lang.Object
io.netty.util.Recycler.LocalPool<T>
- All Implemented Interfaces:
org.jctools.queues.MessagePassingQueue.Consumer<Recycler.DefaultHandle<T>>
private static final class Recycler.LocalPool<T>
extends Object
implements org.jctools.queues.MessagePassingQueue.Consumer<Recycler.DefaultHandle<T>>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ArrayDeque
<Recycler.DefaultHandle<T>> private final int
private Thread
private org.jctools.queues.MessagePassingQueue
<Recycler.DefaultHandle<T>> private int
private final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
(package private) Recycler.DefaultHandle
<T> claim()
private static boolean
isTerminated
(Thread owner) (package private) Recycler.DefaultHandle
<T> (package private) void
release
(Recycler.DefaultHandle<T> handle, boolean guarded)
-
Field Details
-
ratioInterval
private final int ratioInterval -
chunkSize
private final int chunkSize -
batch
-
owner
-
pooledHandles
-
ratioCounter
private int ratioCounter
-
-
Constructor Details
-
LocalPool
LocalPool(int maxCapacity, int ratioInterval, int chunkSize)
-
-
Method Details
-
claim
Recycler.DefaultHandle<T> claim() -
release
-
isTerminated
-
newHandle
Recycler.DefaultHandle<T> newHandle() -
accept
- Specified by:
accept
in interfaceorg.jctools.queues.MessagePassingQueue.Consumer<T>
-