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 java.lang.Object implements org.jctools.queues.MessagePassingQueue.Consumer<Recycler.DefaultHandle<T>>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.ArrayDeque<Recycler.DefaultHandle<T>>
batch
private int
chunkSize
private java.lang.Thread
owner
private org.jctools.queues.MessagePassingQueue<Recycler.DefaultHandle<T>>
pooledHandles
private int
ratioCounter
private int
ratioInterval
-
Constructor Summary
Constructors Constructor Description LocalPool(int maxCapacity, int ratioInterval, int chunkSize)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(Recycler.DefaultHandle<T> e)
(package private) Recycler.DefaultHandle<T>
claim()
private static boolean
isTerminated(java.lang.Thread owner)
(package private) Recycler.DefaultHandle<T>
newHandle()
(package private) void
release(Recycler.DefaultHandle<T> handle, boolean guarded)
-
-
-
Field Detail
-
ratioInterval
private final int ratioInterval
-
chunkSize
private final int chunkSize
-
batch
private final java.util.ArrayDeque<Recycler.DefaultHandle<T>> batch
-
owner
private volatile java.lang.Thread owner
-
pooledHandles
private volatile org.jctools.queues.MessagePassingQueue<Recycler.DefaultHandle<T>> pooledHandles
-
ratioCounter
private int ratioCounter
-
-
Method Detail
-
claim
Recycler.DefaultHandle<T> claim()
-
release
void release(Recycler.DefaultHandle<T> handle, boolean guarded)
-
isTerminated
private static boolean isTerminated(java.lang.Thread owner)
-
newHandle
Recycler.DefaultHandle<T> newHandle()
-
accept
public void accept(Recycler.DefaultHandle<T> e)
- Specified by:
accept
in interfaceorg.jctools.queues.MessagePassingQueue.Consumer<T>
-
-