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>>

Enclosing class:

Recycler<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

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)

Methods inherited from class java.lang.Object

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

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

Constructor Detail

LocalPool

LocalPool(int maxCapacity,
          int ratioInterval,
          int chunkSize)

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 interface org.jctools.queues.MessagePassingQueue.Consumer<T>