Package org.eclipse.jetty.io
Class ByteBufferPool.Bucket
- java.lang.Object
-
- org.eclipse.jetty.io.ByteBufferPool.Bucket
-
- Enclosing interface:
- ByteBufferPool
public static class ByteBufferPool.Bucket extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private int_capacityprivate java.util.concurrent.atomic.AtomicLong_lastUpdateprivate int_maxSizeprivate java.util.function.IntConsumer_memoryFunctionprivate ByteBufferPool_poolprivate java.util.Queue<java.nio.ByteBuffer>_queueprivate java.util.concurrent.atomic.AtomicInteger_size
-
Constructor Summary
Constructors Constructor Description Bucket(ByteBufferPool pool, int capacity, int maxSize)Deprecated.Bucket(ByteBufferPool pool, int capacity, int maxSize, java.util.function.IntConsumer memoryFunction)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description java.nio.ByteBufferacquire()java.nio.ByteBufferacquire(boolean direct)Deprecated.useacquire()insteadvoidclear()(package private) longgetLastUpdate()(package private) booleanisEmpty()voidrelease(java.nio.ByteBuffer buffer)(package private) voidresetUpdateTime()(package private) intsize()java.lang.StringtoString()
-
-
-
Field Detail
-
_queue
private final java.util.Queue<java.nio.ByteBuffer> _queue
-
_pool
private final ByteBufferPool _pool
-
_capacity
private final int _capacity
-
_maxSize
private final int _maxSize
-
_size
private final java.util.concurrent.atomic.AtomicInteger _size
-
_lastUpdate
private final java.util.concurrent.atomic.AtomicLong _lastUpdate
-
_memoryFunction
private final java.util.function.IntConsumer _memoryFunction
-
-
Constructor Detail
-
Bucket
@Deprecated public Bucket(ByteBufferPool pool, int capacity, int maxSize)
Deprecated.
-
Bucket
public Bucket(ByteBufferPool pool, int capacity, int maxSize, java.util.function.IntConsumer memoryFunction)
-
-
Method Detail
-
acquire
public java.nio.ByteBuffer acquire()
-
acquire
@Deprecated public java.nio.ByteBuffer acquire(boolean direct)
Deprecated.useacquire()instead- Parameters:
direct- whether to create a direct buffer when none is available- Returns:
- a ByteBuffer
-
release
public void release(java.nio.ByteBuffer buffer)
-
resetUpdateTime
void resetUpdateTime()
-
clear
public void clear()
-
isEmpty
boolean isEmpty()
-
size
int size()
-
getLastUpdate
long getLastUpdate()
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-