Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	ByteBufferSlicePool.PooledByteBuffer References Deprecated `Pooled` is deprecated or references (maybe indirectly) at least one deprecated element.
pack-priv class	ByteBufferSlicePool.Ref References Deprecated `AutomaticReference` is deprecated or references (maybe indirectly) at least one deprecated element.
private static class	ByteBufferSlicePool.Slice
pack-priv static class	ByteBufferSlicePool.ThreadLocalCache
private static class	ByteBufferSlicePool.ThreadLocalCacheWrapper

Field Summary

Modifier and Type	Field and Description
private final BufferAllocator<ByteBuffer>	allocator
private final int	bufferSize
private final int	buffersPerRegion
private final List<ByteBuffer>	directBuffers
private static final Queue<ByteBuffer>	FREE_DIRECT_BUFFERS
private static final int	LOCAL_LENGTH
private final ThreadLocal<ByteBufferSlicePool.ThreadLocalCache>	localQueueHolder
private final Set<ByteBufferSlicePool.Ref>	refSet
private final Queue<ByteBufferSlicePool.Slice>	sliceQueue
private final int	threadLocalQueueSize

Access	Constructor and Description
public	ByteBufferSlicePool(final BufferAllocator<ByteBuffer> the buffer allocator to use allocator, final int the size of each buffer bufferSize, final int the maximum region size for each backing buffer maxRegionSize, final int the number of buffers to cache on each thread threadLocalQueueSize) Construct a new instance.
public	ByteBufferSlicePool(final BufferAllocator<ByteBuffer> the buffer allocator to use allocator, final int the size of each buffer bufferSize, final int the maximum region size for each backing buffer maxRegionSize) Construct a new instance.
public	ByteBufferSlicePool(final int the size of each buffer bufferSize, final int the maximum region size for each backing buffer maxRegionSize) Construct a new instance, using a direct buffer allocator.

Method Summary

Modifier and Type	Method and Description
public Pooled<ByteBuffer>	allocate() Implements org.xnio.Pool.allocate. References Deprecated `Pooled` is deprecated or references (maybe indirectly) at least one deprecated element. Allocate a resource from the pool.
private ByteBufferSlicePool.Slice	allocateSlices(final int buffersPerRegion, final int bufferSize)
public void	clean() Cleans the pool, removing references to any buffers inside it.
private ByteBufferSlicePool.ThreadLocalCache	createThreadLocalCache()
private void	doFree(ByteBufferSlicePool.Slice region)
private void	freeThreadLocalCache(ByteBufferSlicePool.ThreadLocalCache cache)
public int	getBufferSize() Return the size of the `ByteBuffer`s that are returned by `allocate()`.
private ByteBufferSlicePool.Slice	sliceAllocatedBuffer(final ByteBuffer region, final int buffersPerRegion, final int bufferSize)
private ByteBufferSlicePool.Slice	sliceReusedBuffer(final ByteBuffer region, final int buffersPerRegion, final int bufferSize)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allocator	back to summary
private final BufferAllocator<ByteBuffer> allocator

bufferSize	back to summary
private final int bufferSize

buffersPerRegion	back to summary
private final int buffersPerRegion

directBuffers	back to summary
private final List<ByteBuffer> directBuffers

FREE_DIRECT_BUFFERS	back to summary
private static final Queue<ByteBuffer> FREE_DIRECT_BUFFERS

LOCAL_LENGTH	back to summary
private static final int LOCAL_LENGTH

localQueueHolder	back to summary
private final ThreadLocal<ByteBufferSlicePool.ThreadLocalCache> localQueueHolder

refSet	back to summary
private final Set<ByteBufferSlicePool.Ref> refSet

sliceQueue	back to summary
private final Queue<ByteBufferSlicePool.Slice> sliceQueue

threadLocalQueueSize	back to summary
private final int threadLocalQueueSize

Constructor Detail

ByteBufferSlicePool	back to summary
public ByteBufferSlicePool(final BufferAllocator<ByteBuffer> allocator, final int bufferSize, final int maxRegionSize, final int threadLocalQueueSize) Construct a new instance. Parameters allocator:BufferAllocator<ByteBuffer> the buffer allocator to use bufferSize:int the size of each buffer maxRegionSize:int the maximum region size for each backing buffer threadLocalQueueSize:int the number of buffers to cache on each thread

ByteBufferSlicePool

back to summary

public ByteBufferSlicePool(final BufferAllocator<ByteBuffer> allocator, final int bufferSize, final int maxRegionSize, final int threadLocalQueueSize)

Construct a new instance.

Parameters

allocator:BufferAllocator<ByteBuffer>: the buffer allocator to use
bufferSize:int: the size of each buffer
maxRegionSize:int: the maximum region size for each backing buffer
threadLocalQueueSize:int: the number of buffers to cache on each thread

ByteBufferSlicePool	back to summary
public ByteBufferSlicePool(final BufferAllocator<ByteBuffer> allocator, final int bufferSize, final int maxRegionSize) Construct a new instance. Parameters allocator:BufferAllocator<ByteBuffer> the buffer allocator to use bufferSize:int the size of each buffer maxRegionSize:int the maximum region size for each backing buffer

ByteBufferSlicePool

back to summary

public ByteBufferSlicePool(final BufferAllocator<ByteBuffer> allocator, final int bufferSize, final int maxRegionSize)

Construct a new instance.

Parameters

allocator:BufferAllocator<ByteBuffer>: the buffer allocator to use
bufferSize:int: the size of each buffer
maxRegionSize:int: the maximum region size for each backing buffer

ByteBufferSlicePool	back to summary
public ByteBufferSlicePool(final int bufferSize, final int maxRegionSize) Construct a new instance, using a direct buffer allocator. Parameters bufferSize:int the size of each buffer maxRegionSize:int the maximum region size for each backing buffer

ByteBufferSlicePool

back to summary

public ByteBufferSlicePool(final int bufferSize, final int maxRegionSize)

Construct a new instance, using a direct buffer allocator.

Parameters

bufferSize:int: the size of each buffer
maxRegionSize:int: the maximum region size for each backing buffer

Method Detail

allocate back to summary

allocate	back to summary
public Pooled<ByteBuffer> allocate() Implements org.xnio.Pool.allocate. Doc from org.xnio.Pool.allocate. References Deprecated `Pooled` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Allocate a resource from the pool. Returns:Pooled<ByteBuffer> the resource

public Pooled<ByteBuffer> allocate()

Implements org.xnio.Pool.allocate.

Doc from org.xnio.Pool.allocate.

References Deprecated

Pooled is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Allocate a resource from the pool.

Returns:Pooled<ByteBuffer>: the resource

allocateSlices	back to summary
private ByteBufferSlicePool.Slice allocateSlices(final int buffersPerRegion, final int bufferSize)

clean	back to summary
public void clean() Cleans the pool, removing references to any buffers inside it. Should be invoked on pool disposal, when the pool will no longer be used.

createThreadLocalCache	back to summary
private ByteBufferSlicePool.ThreadLocalCache createThreadLocalCache()

doFree	back to summary
private void doFree(ByteBufferSlicePool.Slice region)

freeThreadLocalCache	back to summary
private void freeThreadLocalCache(ByteBufferSlicePool.ThreadLocalCache cache)

getBufferSize	back to summary
public int getBufferSize() Return the size of the `ByteBuffer`s that are returned by `allocate()`.

sliceAllocatedBuffer	back to summary
private ByteBufferSlicePool.Slice sliceAllocatedBuffer(final ByteBuffer region, final int buffersPerRegion, final int bufferSize)

sliceReusedBuffer	back to summary
private ByteBufferSlicePool.Slice sliceReusedBuffer(final ByteBuffer region, final int buffersPerRegion, final int bufferSize)

org.xnio back to summary

private final Class ByteBufferSlicePool.PooledByteBuffer

Class Inheritance

extends Object
implements Pooled<ByteBuffer>

java.lang.Object
org.xnio.ByteBufferSlicePool.PooledByteBuffer

All Implemented Interfaces

org.xnio.Pooled, java.lang.AutoCloseable

References Deprecated

Pooled is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Field Summary

Modifier and Type	Field and Description
pack-priv ByteBuffer	buffer
private final ByteBufferSlicePool.Slice	region

Constructor Summary

Access	Constructor and Description
pack-priv	PooledByteBuffer(final ByteBufferSlicePool.Slice region, final ByteBuffer buffer)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements org.xnio.Pooled.close. Delegates to `free()`.
public void	discard() Implements org.xnio.Pooled.discard. Discard this resource.
public void	free() Implements org.xnio.Pooled.free. Free this resource for immediate re-use.
public ByteBuffer	getResource() Implements org.xnio.Pooled.getResource. Get the pooled resource.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

buffer	back to summary
pack-priv ByteBuffer buffer

region	back to summary
private final ByteBufferSlicePool.Slice region

Constructor Detail

PooledByteBuffer	back to summary
pack-priv PooledByteBuffer(final ByteBufferSlicePool.Slice region, final ByteBuffer buffer)

Method Detail

close back to summary

close	back to summary
public void close() Implements org.xnio.Pooled.close. Doc from org.xnio.Pooled.close. Delegates to `free()`.

public void close()

Implements org.xnio.Pooled.close.

Doc from org.xnio.Pooled.close.

Delegates to free().

discard	back to summary
public void discard() Implements org.xnio.Pooled.discard. Doc from org.xnio.Pooled.discard. Discard this resource. Any backing resources corresponding to this pooled resource will be rendered unavailable until the pooled resource has been garbage-collected.

discard

back to summary

public void discard()

Implements org.xnio.Pooled.discard.

Doc from org.xnio.Pooled.discard.

Discard this resource. Any backing resources corresponding to this pooled resource will be rendered unavailable until the pooled resource has been garbage-collected.

free back to summary

free	back to summary
public void free() Implements org.xnio.Pooled.free. Doc from org.xnio.Pooled.free. Free this resource for immediate re-use. The resource must not be accessed again after calling this method; if it is possible that an instance is still in use, you must call `discard()` instead.

public void free()

Implements org.xnio.Pooled.free.

Doc from org.xnio.Pooled.free.

Free this resource for immediate re-use. The resource must not be accessed again after calling this method; if it is possible that an instance is still in use, you must call discard() instead.

getResource	back to summary
public ByteBuffer getResource() Implements org.xnio.Pooled.getResource. Doc from org.xnio.Pooled.getResource. Get the pooled resource. Returns:ByteBuffer the pooled resource

getResource

back to summary

public ByteBuffer getResource()

Implements org.xnio.Pooled.getResource.

Doc from org.xnio.Pooled.getResource.

Get the pooled resource.

Returns:ByteBuffer: the pooled resource

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String: a string representation of the object

org.xnio back to summary

pack-priv final Class ByteBufferSlicePool.Ref

Class Inheritance

extends AutomaticReference<ByteBuffer>

References Deprecated

AutomaticReference is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Field Summary

Modifier and Type	Field and Description
private final ByteBufferSlicePool.Slice	region

Inherited from org.xnio.AutomaticReference:: PERMIT

Constructor Summary

Access	Constructor and Description
private	Ref(final ByteBuffer referent, final ByteBufferSlicePool.Slice region)

Method Summary

Modifier and Type	Method and Description
protected void	free() Implements abstract org.xnio.AutomaticReference.free. Free this reference.

Inherited from org.xnio.AutomaticReference:: clear enqueue get getPermit isEnqueued

Field Detail

region	back to summary
private final ByteBufferSlicePool.Slice region

Constructor Detail

Ref	back to summary
private Ref(final ByteBuffer referent, final ByteBufferSlicePool.Slice region)

Method Detail

free	back to summary
protected void free() Implements abstract org.xnio.AutomaticReference.free. Doc from org.xnio.AutomaticReference.free. Free this reference. This method will be called from a dedicated thread or threads so this method should execute as quickly as possible.

free

back to summary

protected void free()

Implements abstract org.xnio.AutomaticReference.free.

Doc from org.xnio.AutomaticReference.free.

Free this reference. This method will be called from a dedicated thread or threads so this method should execute as quickly as possible.

org.xnio back to summary

private final Class ByteBufferSlicePool.Slice

Class Inheritance

extends Object

java.lang.Object
org.xnio.ByteBufferSlicePool.Slice

Field Summary

Modifier and Type	Field and Description
private final ByteBuffer	parent

Constructor Summary

Access	Constructor and Description
private	Slice(final ByteBuffer parent, final int start, final int size)

Method Summary

Modifier and Type	Method and Description
pack-priv ByteBuffer	slice()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

parent	back to summary
private final ByteBuffer parent

Constructor Detail

Slice	back to summary
private Slice(final ByteBuffer parent, final int start, final int size)

Method Detail

slice	back to summary
pack-priv ByteBuffer slice()

org.xnio back to summary

pack-priv final Class ByteBufferSlicePool.ThreadLocalCache

Class Inheritance

extends Object

java.lang.Object
org.xnio.ByteBufferSlicePool.ThreadLocalCache

Field Summary

Modifier and Type	Field and Description
pack-priv int	outstanding
pack-priv final WeakReference<ByteBufferSlicePool>	pool
pack-priv final ArrayDeque<ByteBufferSlicePool.Slice>	queue

Constructor Summary

Access	Constructor and Description
pack-priv	ThreadLocalCache(ByteBufferSlicePool pool) References Deprecated `ByteBufferSlicePool` is deprecated or references (maybe indirectly) at least one deprecated element.

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

outstanding	back to summary
pack-priv int outstanding

pool	back to summary
pack-priv final WeakReference<ByteBufferSlicePool> pool

queue	back to summary
pack-priv final ArrayDeque<ByteBufferSlicePool.Slice> queue

Constructor Detail

ThreadLocalCache	back to summary
pack-priv ThreadLocalCache(ByteBufferSlicePool pool) References Deprecated `ByteBufferSlicePool` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

org.xnio back to summary

private Class ByteBufferSlicePool.ThreadLocalCacheWrapper

Class Inheritance

extends ThreadLocal<ByteBufferSlicePool.ThreadLocalCache>

java.lang.Object
java.lang.ThreadLocal
org.xnio.ByteBufferSlicePool.ThreadLocalCacheWrapper

Field Summary

Modifier and Type	Field and Description
private final WeakReference<ByteBufferSlicePool>	pool

Constructor Summary

Access	Constructor and Description
pack-priv	ThreadLocalCacheWrapper(ByteBufferSlicePool pool) References Deprecated `ByteBufferSlicePool` is deprecated or references (maybe indirectly) at least one deprecated element.

Method Summary

Modifier and Type	Method and Description
protected ByteBufferSlicePool.ThreadLocalCache	initialValue() Overrides java.lang.ThreadLocal.initialValue. Returns the current thread's "initial value" for this thread-local variable.
public void	remove() Overrides java.lang.ThreadLocal.remove. Removes the current thread's value for this thread-local variable.

Inherited from java.lang.ThreadLocal:: get set withInitial

Field Detail

pool	back to summary
private final WeakReference<ByteBufferSlicePool> pool

Constructor Detail

ThreadLocalCacheWrapper	back to summary
pack-priv ThreadLocalCacheWrapper(ByteBufferSlicePool pool) References Deprecated `ByteBufferSlicePool` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

Method Detail

initialValue back to summary

protected ByteBufferSlicePool.ThreadLocalCache initialValue()

Overrides java.lang.ThreadLocal.initialValue.

Doc from java.lang.ThreadLocal.initialValue.

Returns the current thread's "initial value" for this thread-local variable. This method will be invoked the first time a thread accesses the variable with the get method, unless the thread previously invoked the set method, in which case the initialValue method will not be invoked for the thread. Normally, this method is invoked at most once per thread, but it may be invoked again in case of subsequent invocations of remove followed by get.

Returns:ByteBufferSlicePool.ThreadLocalCache: the initial value for this thread-local

remove back to summary

public void remove()

Overrides java.lang.ThreadLocal.remove.

Doc from java.lang.ThreadLocal.remove.

Removes the current thread's value for this thread-local variable. If this thread-local variable is subsequently read by the current thread, its value will be reinitialized by invoking its initialValue method, unless its value is set by the current thread in the interim. This may result in multiple invocations of the initialValue method in the current thread.

public final Class ByteBufferSlicePool

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class ByteBufferSlicePool.PooledByteBuffer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ByteBufferSlicePool.Ref

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class ByteBufferSlicePool.Slice

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ByteBufferSlicePool.ThreadLocalCache

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private Class ByteBufferSlicePool.ThreadLocalCacheWrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail