Class CachedBufferAllocator
- java.lang.Object
-
- com.google.code.yanf4j.buffer.CachedBufferAllocator
-
- All Implemented Interfaces:
IoBufferAllocator
public class CachedBufferAllocator extends java.lang.Object implements IoBufferAllocator
AnIoBufferAllocator
that caches the buffers which are likely to be reused during auto-expansion of the buffers.In
SimpleBufferAllocator
, the underlyingByteBuffer
of theIoBuffer
is reallocated on its capacity change, which means the newly allocated biggerByteBuffer
replaces the old smallByteBuffer
. Consequently, the oldByteBuffer
is marked for garbage collection.It's not a problem in most cases as long as the capacity change doesn't happen frequently. However, once it happens too often, it burdens the VM and the cost of filling the newly allocated
ByteBuffer
withNUL
surpass the cost of accessing the cache. In 2 dual-core Opteron Italy 270 processors,CachedBufferAllocator
outperformedSimpleBufferAllocator
in the following situation:- when a 32 bytes buffer is expanded 4 or more times,
- when a 64 bytes buffer is expanded 4 or more times,
- when a 128 bytes buffer is expanded 2 or more times,
- and when a 256 bytes or bigger buffer is expanded 1 or more times.
CachedBufferAllocator
usesThreadLocal
to store the cached buffer, allocates buffers whose capacity is power of 2 only and provides performance advantage ifIoBuffer.free()
is called properly.- Version:
- $Rev: 671827 $, $Date: 2008-06-26 10:49:48 +0200 (Thu, 26 Jun 2008) $
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
CachedBufferAllocator.CachedBuffer
-
Field Summary
Fields Modifier and Type Field Description private static int
DEFAULT_MAX_CACHED_BUFFER_SIZE
private static int
DEFAULT_MAX_POOL_SIZE
private java.lang.ThreadLocal<java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>>>
directBuffers
private java.lang.ThreadLocal<java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>>>
heapBuffers
private int
maxCachedBufferSize
private int
maxPoolSize
-
Constructor Summary
Constructors Constructor Description CachedBufferAllocator()
Creates a new instance with the default parameters (#DEFAULT_MAX_POOL_SIZE and #DEFAULT_MAX_CACHED_BUFFER_SIZE).CachedBufferAllocator(int maxPoolSize, int maxCachedBufferSize)
Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description IoBuffer
allocate(int requestedCapacity, boolean direct)
Returns the buffer which is capable of the specified size.java.nio.ByteBuffer
allocateNioBuffer(int capacity, boolean direct)
Returns the NIO buffer which is capable of the specified size.void
dispose()
Dispose of this allocator.int
getMaxCachedBufferSize()
Returns the maximum capacity of a cached buffer.int
getMaxPoolSize()
Returns the maximum number of buffers with the same capacity per thread.private java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>>
newPoolMap()
IoBuffer
wrap(java.nio.ByteBuffer nioBuffer)
Wraps the specified NIOByteBuffer
into MINA buffer.
-
-
-
Field Detail
-
DEFAULT_MAX_POOL_SIZE
private static final int DEFAULT_MAX_POOL_SIZE
- See Also:
- Constant Field Values
-
DEFAULT_MAX_CACHED_BUFFER_SIZE
private static final int DEFAULT_MAX_CACHED_BUFFER_SIZE
- See Also:
- Constant Field Values
-
maxPoolSize
private final int maxPoolSize
-
maxCachedBufferSize
private final int maxCachedBufferSize
-
heapBuffers
private final java.lang.ThreadLocal<java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>>> heapBuffers
-
directBuffers
private final java.lang.ThreadLocal<java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>>> directBuffers
-
-
Constructor Detail
-
CachedBufferAllocator
public CachedBufferAllocator()
Creates a new instance with the default parameters (#DEFAULT_MAX_POOL_SIZE and #DEFAULT_MAX_CACHED_BUFFER_SIZE).
-
CachedBufferAllocator
public CachedBufferAllocator(int maxPoolSize, int maxCachedBufferSize)
Creates a new instance.- Parameters:
maxPoolSize
- the maximum number of buffers with the same capacity per thread. 0 disables this limitation.maxCachedBufferSize
- the maximum capacity of a cached buffer. A buffer whose capacity is bigger than this value is not pooled. 0 disables this limitation.
-
-
Method Detail
-
getMaxPoolSize
public int getMaxPoolSize()
Returns the maximum number of buffers with the same capacity per thread. 0 means 'no limitation'.
-
getMaxCachedBufferSize
public int getMaxCachedBufferSize()
Returns the maximum capacity of a cached buffer. A buffer whose capacity is bigger than this value is not pooled. 0 means 'no limitation'.
-
newPoolMap
private java.util.Map<java.lang.Integer,java.util.Queue<CachedBufferAllocator.CachedBuffer>> newPoolMap()
-
allocate
public IoBuffer allocate(int requestedCapacity, boolean direct)
Description copied from interface:IoBufferAllocator
Returns the buffer which is capable of the specified size.- Specified by:
allocate
in interfaceIoBufferAllocator
- Parameters:
requestedCapacity
- the capacity of the bufferdirect
- true to get a direct buffer, false to get a heap buffer.
-
allocateNioBuffer
public java.nio.ByteBuffer allocateNioBuffer(int capacity, boolean direct)
Description copied from interface:IoBufferAllocator
Returns the NIO buffer which is capable of the specified size.- Specified by:
allocateNioBuffer
in interfaceIoBufferAllocator
- Parameters:
capacity
- the capacity of the bufferdirect
- true to get a direct buffer, false to get a heap buffer.
-
wrap
public IoBuffer wrap(java.nio.ByteBuffer nioBuffer)
Description copied from interface:IoBufferAllocator
Wraps the specified NIOByteBuffer
into MINA buffer.- Specified by:
wrap
in interfaceIoBufferAllocator
-
dispose
public void dispose()
Description copied from interface:IoBufferAllocator
Dispose of this allocator.- Specified by:
dispose
in interfaceIoBufferAllocator
-
-