Modifier and Type	Class and Description
private static class	Recycler.BlockingMessageQueue<T> This is an implementation of `MessagePassingQueue`, similar to what might be returned from `PlatformDependent#newMpscQueue(int)`, but intended to be used for debugging purpose.
private static class	Recycler.DefaultHandle<T>
public static interface	Recycler.Handle<T>
private static class	Recycler.LocalPool<T>

Modifier and Type	Field and Description
private static final boolean	BLOCKING_POOL
private final int	chunkSize
private static final int	DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD
private static final int	DEFAULT_MAX_CAPACITY_PER_THREAD
private static final int	DEFAULT_QUEUE_CHUNK_SIZE_PER_THREAD
private final int	interval
private static final InternalLogger	logger
private final int	maxCapacityPerThread
private static final Recycler.Handle<?>	NOOP_HANDLE
private static final int	RATIO
private final FastThreadLocal<Recycler.LocalPool<T>>	threadLocal

Access	Constructor and Description
protected	Recycler()
protected	Recycler(int maxCapacityPerThread)
protected	Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`.
protected	Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor, int ratio, int maxDelayedQueuesPerThread) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`.
protected	Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor, int ratio, int maxDelayedQueuesPerThread, int delayedQueueRatio) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`.
protected	Recycler(int maxCapacityPerThread, int ratio, int chunkSize)

Modifier and Type	Method and Description
public final T	get()
protected abstract T	newObject(Recycler.Handle<T> handle)
public final boolean	recycle(T o, Recycler.Handle<T> handle) Deprecated use `Handle#recycle(Object)`.
pack-priv final int	threadLocalSize()

BLOCKING_POOL	back to summary
private static final boolean BLOCKING_POOL

chunkSize	back to summary
private final int chunkSize

DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD	back to summary
private static final int DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD

DEFAULT_MAX_CAPACITY_PER_THREAD	back to summary
private static final int DEFAULT_MAX_CAPACITY_PER_THREAD

DEFAULT_QUEUE_CHUNK_SIZE_PER_THREAD	back to summary
private static final int DEFAULT_QUEUE_CHUNK_SIZE_PER_THREAD

interval	back to summary
private final int interval

logger	back to summary
private static final InternalLogger logger

maxCapacityPerThread	back to summary
private final int maxCapacityPerThread

NOOP_HANDLE	back to summary
private static final Recycler.Handle<?> NOOP_HANDLE

RATIO	back to summary
private static final int RATIO

threadLocal	back to summary
private final FastThreadLocal<Recycler.LocalPool<T>> threadLocal

Recycler	back to summary
protected Recycler()

Recycler	back to summary
protected Recycler(int maxCapacityPerThread)

Recycler	back to summary
protected Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`. Annotations @Deprecated @SuppressWarnings:unused

Recycler	back to summary
protected Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor, int ratio, int maxDelayedQueuesPerThread) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`. Annotations @Deprecated @SuppressWarnings:unused

Recycler	back to summary
protected Recycler(int maxCapacityPerThread, int maxSharedCapacityFactor, int ratio, int maxDelayedQueuesPerThread, int delayedQueueRatio) Deprecated Use one of the following instead: `Recycler()`, `Recycler(int)`, `Recycler(int, int, int)`. Annotations @Deprecated @SuppressWarnings:unused

Recycler	back to summary
protected Recycler(int maxCapacityPerThread, int ratio, int chunkSize)

get	back to summary
public final T get() Annotations @SuppressWarnings:unchecked

newObject	back to summary
protected abstract T newObject(Recycler.Handle<T> handle)

recycle	back to summary
public final boolean recycle(T o, Recycler.Handle<T> handle) Deprecated use `Handle#recycle(Object)`. Annotations @Deprecated

threadLocalSize	back to summary
pack-priv final int threadLocalSize()

private final Class Recycler.BlockingMessageQueue<T>

Class Inheritance

extends Object
implements MessagePassingQueue<T>

java.lang.Object
io.netty5.util.Recycler.BlockingMessageQueue

All Implemented Interfaces

io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue

This is an implementation of MessagePassingQueue, similar to what might be returned from PlatformDependent#newMpscQueue(int), but intended to be used for debugging purpose. The implementation relies on synchronised monitor locks for thread-safety. The drain and fill bulk operations are not supported by this implementation.

Field Summary

Modifier and Type	Field and Description
private final Queue<T>	deque
private final int	maxCapacity

Constructor Summary

Access	Constructor and Description
pack-priv	BlockingMessageQueue(int maxCapacity)

Method Summary

Modifier and Type	Method and Description
public int	capacity() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity.
public synchronized void	clear() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.clear. Removes all items from the queue.
public int	drain(MessagePassingQueue.Consumer<T> c, int limit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove up to limit elements from the queue and hand to consume.
public int	drain(MessagePassingQueue.Consumer<T> c) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove all available item from the queue and hand to consume.
public void	drain(MessagePassingQueue.Consumer<T> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove elements from the queue and hand to consume forever.
public int	fill(MessagePassingQueue.Supplier<T> s, int limit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with up to limit elements from the supplier.
public int	fill(MessagePassingQueue.Supplier<T> s) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with elements from the supplier.
public void	fill(MessagePassingQueue.Supplier<T> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with elements from the supplier forever.
public synchronized boolean	isEmpty() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty. This method's accuracy is subject to concurrent modifications happening as the observation is carried out.
public synchronized boolean	offer(T not `null`, will throw NPE if it is e) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer. Called from a producer thread subject to the restrictions appropriate to the implementation and according to the `Queue#offer(Object)` interface.
public synchronized T	peek() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the `Queue#peek()` interface.
public synchronized T	poll() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the `Queue#poll()` interface.
public boolean	relaxedOffer(T not `null`, will throw NPE if it is e) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedOffer. Called from a producer thread subject to the restrictions appropriate to the implementation.
public T	relaxedPeek() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPeek. Called from the consumer thread subject to the restrictions appropriate to the implementation.
public T	relaxedPoll() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPoll. Called from the consumer thread subject to the restrictions appropriate to the implementation.
public synchronized int	size() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size. This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value.

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

Field Detail

deque	back to summary
private final Queue<T> deque

maxCapacity	back to summary
private final int maxCapacity

Constructor Detail

BlockingMessageQueue	back to summary
pack-priv BlockingMessageQueue(int maxCapacity)

Method Detail

capacity back to summary

capacity	back to summary
public int capacity() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity. Returns:int Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity. the capacity of this queue or `MessagePassingQueue#UNBOUNDED_CAPACITY` if not bounded Annotations @Override

public int capacity()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity.

Returns:int

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity.

the capacity of this queue or MessagePassingQueue#UNBOUNDED_CAPACITY if not bounded

Annotations

@Override

clear back to summary

clear	back to summary
public synchronized void clear() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.clear. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.clear. Removes all items from the queue. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the `Queue#clear()` interface. Annotations @Override

public synchronized void clear()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.clear.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.clear.

Removes all items from the queue. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue#clear() interface.

Annotations

@Override

drain back to summary

drain	back to summary
public int drain(MessagePassingQueue.Consumer<T> c, int limit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove up to limit elements from the queue and hand to consume. This should be semantically similar to: `M m; int i = 0; for(;i < limit && (m = relaxedPoll()) != null; i++){ c.accept(m); } return i;` There's no strong commitment to the queue being empty at the end of a drain. Called from a consumer thread subject to the restrictions appropriate to the implementation. Warning Explicit assumptions are made with regards to `Consumer#accept` make sure you have read and understood these before using this method. Returns:int the number of polled elements Annotations @Override

public int drain(MessagePassingQueue.Consumer<T> c, int limit)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Remove up to limit elements from the queue and hand to consume. This should be semantically similar to:

M m;
  int i = 0;
  for(;i < limit && (m = relaxedPoll()) != null; i++){
    c.accept(m);
  }
  return i;

There's no strong commitment to the queue being empty at the end of a drain. Called from a consumer thread subject to the restrictions appropriate to the implementation.

Warning

Explicit assumptions are made with regards to Consumer#accept make sure you have read and understood these before using this method.

Returns:int

the number of polled elements

Annotations

@Override

drain back to summary

drain	back to summary
public int drain(MessagePassingQueue.Consumer<T> c) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove all available item from the queue and hand to consume. This should be semantically similar to: M m; while((m = relaxedPoll()) != null){ c.accept(m); } There's no strong commitment to the queue being empty at the end of a drain. Called from a consumer thread subject to the restrictions appropriate to the implementation. Warning Explicit assumptions are made with regards to `Consumer#accept` make sure you have read and understood these before using this method. Returns:int the number of polled elements Annotations @Override

public int drain(MessagePassingQueue.Consumer<T> c)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Remove all available item from the queue and hand to consume. This should be semantically similar to:

M m;
while((m = relaxedPoll()) != null){
c.accept(m);
}

There's no strong commitment to the queue being empty at the end of a drain. Called from a consumer thread subject to the restrictions appropriate to the implementation.

Warning

Explicit assumptions are made with regards to Consumer#accept make sure you have read and understood these before using this method.

Returns:int

the number of polled elements

Annotations

@Override

drain back to summary

drain	back to summary
public void drain(MessagePassingQueue.Consumer<T> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain. Remove elements from the queue and hand to consume forever. Semantically similar to: int idleCounter = 0; while (exit.keepRunning()) { E e = relaxedPoll(); if(e==null){ idleCounter = wait.idle(idleCounter); continue; } idleCounter = 0; c.accept(e); } Called from a consumer thread subject to the restrictions appropriate to the implementation. Warning Explicit assumptions are made with regards to `Consumer#accept` make sure you have read and understood these before using this method. Annotations @Override

public void drain(MessagePassingQueue.Consumer<T> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Remove elements from the queue and hand to consume forever. Semantically similar to:

 int idleCounter = 0;
 while (exit.keepRunning()) {
     E e = relaxedPoll();
     if(e==null){
         idleCounter = wait.idle(idleCounter);
         continue;
     }
     idleCounter = 0;
     c.accept(e);
 }

Called from a consumer thread subject to the restrictions appropriate to the implementation.

Warning

Explicit assumptions are made with regards to Consumer#accept make sure you have read and understood these before using this method.

Annotations

@Override

fill back to summary

fill	back to summary
public int fill(MessagePassingQueue.Supplier<T> s, int limit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with up to limit elements from the supplier. Semantically similar to: `for(int i=0; i < limit && relaxedOffer(s.get()); i++);` There's no strong commitment to the queue being full at the end of a fill. Called from a producer thread subject to the restrictions appropriate to the implementation Warning Explicit assumptions are made with regards to `Supplier#get` make sure you have read and understood these before using this method. Returns:int the number of offered elements Annotations @Override

public int fill(MessagePassingQueue.Supplier<T> s, int limit)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Stuff the queue with up to limit elements from the supplier. Semantically similar to:

for(int i=0; i < limit && relaxedOffer(s.get()); i++);

There's no strong commitment to the queue being full at the end of a fill. Called from a producer thread subject to the restrictions appropriate to the implementation

Warning

Explicit assumptions are made with regards to Supplier#get make sure you have read and understood these before using this method.

Returns:int

the number of offered elements

Annotations

@Override

fill back to summary

fill	back to summary
public int fill(MessagePassingQueue.Supplier<T> s) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with elements from the supplier. Semantically similar to: while(relaxedOffer(s.get()); There's no strong commitment to the queue being full at the end of a fill. Called from a producer thread subject to the restrictions appropriate to the implementation. Unbounded queues will fill up the queue with a fixed amount rather than fill up to oblivion Warning Explicit assumptions are made with regards to `Supplier#get` make sure you have read and understood these before using this method. Returns:int the number of offered elements Annotations @Override

public int fill(MessagePassingQueue.Supplier<T> s)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Stuff the queue with elements from the supplier. Semantically similar to:

while(relaxedOffer(s.get());

There's no strong commitment to the queue being full at the end of a fill. Called from a producer thread subject to the restrictions appropriate to the implementation.

Unbounded queues will fill up the queue with a fixed amount rather than fill up to oblivion

Warning

Explicit assumptions are made with regards to Supplier#get make sure you have read and understood these before using this method.

Returns:int

the number of offered elements

Annotations

@Override

fill back to summary

fill	back to summary
public void fill(MessagePassingQueue.Supplier<T> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill. Stuff the queue with elements from the supplier forever. Semantically similar to: `int idleCounter = 0; while (exit.keepRunning()) { E e = s.get(); while (!relaxedOffer(e)) { idleCounter = wait.idle(idleCounter); continue; } idleCounter = 0; }` Called from a producer thread subject to the restrictions appropriate to the implementation. The main difference being that implementors MUST assure room in the queue is available BEFORE calling `Supplier#get` Warning Explicit assumptions are made with regards to `Supplier#get` make sure you have read and understood these before using this method. Annotations @Override

public void fill(MessagePassingQueue.Supplier<T> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Stuff the queue with elements from the supplier forever. Semantically similar to:


 int idleCounter = 0;
 while (exit.keepRunning()) {
     E e = s.get();
     while (!relaxedOffer(e)) {
         idleCounter = wait.idle(idleCounter);
         continue;
     }
     idleCounter = 0;
 }

Called from a producer thread subject to the restrictions appropriate to the implementation. The main difference being that implementors MUST assure room in the queue is available BEFORE calling Supplier#get

Warning

Explicit assumptions are made with regards to Supplier#get make sure you have read and understood these before using this method.

Annotations

@Override

isEmpty	back to summary
public synchronized boolean isEmpty() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty. This method's accuracy is subject to concurrent modifications happening as the observation is carried out. Returns:boolean true if empty, false otherwise Annotations @Override

isEmpty

back to summary

public synchronized boolean isEmpty()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty.

This method's accuracy is subject to concurrent modifications happening as the observation is carried out.

Returns:boolean

true if empty, false otherwise

Annotations

@Override

offer back to summary

offer	back to summary
public synchronized boolean offer(T e) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer. Called from a producer thread subject to the restrictions appropriate to the implementation and according to the `Queue#offer(Object)` interface. Parameters e:T not `null`, will throw NPE if it is Returns:boolean true if element was inserted into the queue, false iff full Annotations @Override

public synchronized boolean offer(T e)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer.

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue#offer(Object) interface.

Parameters

e:T: not null, will throw NPE if it is

Returns:boolean

true if element was inserted into the queue, false iff full

Annotations

@Override

peek back to summary

peek	back to summary
public synchronized T peek() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the `Queue#peek()` interface. Returns:T a message from the queue if one is available, `null` iff empty Annotations @Override

public synchronized T peek()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek.

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue#peek() interface.

Returns:T

a message from the queue if one is available, null iff empty

Annotations

@Override

poll back to summary

poll	back to summary
public synchronized T poll() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll. Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the `Queue#poll()` interface. Returns:T a message from the queue if one is available, `null` iff empty Annotations @Override

public synchronized T poll()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll.

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue#poll() interface.

Returns:T

a message from the queue if one is available, null iff empty

Annotations

@Override

relaxedOffer back to summary

relaxedOffer	back to summary
public boolean relaxedOffer(T e) Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedOffer. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedOffer. Called from a producer thread subject to the restrictions appropriate to the implementation. As opposed to `Queue#offer(Object)` this method may return false without the queue being full. Parameters e:T not `null`, will throw NPE if it is Returns:boolean true if element was inserted into the queue, false if unable to offer Annotations @Override

public boolean relaxedOffer(T e)

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedOffer.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedOffer.

Called from a producer thread subject to the restrictions appropriate to the implementation. As opposed to Queue#offer(Object) this method may return false without the queue being full.

Parameters

e:T: not null, will throw NPE if it is

Returns:boolean

true if element was inserted into the queue, false if unable to offer

Annotations

@Override

relaxedPeek back to summary

relaxedPeek	back to summary
public T relaxedPeek() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPeek. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPeek. Called from the consumer thread subject to the restrictions appropriate to the implementation. As opposed to `Queue#peek()` this method may return `null` without the queue being empty. Returns:T a message from the queue if one is available, `null` if unable to peek Annotations @Override

public T relaxedPeek()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPeek.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPeek.

Called from the consumer thread subject to the restrictions appropriate to the implementation. As opposed to Queue#peek() this method may return null without the queue being empty.

Returns:T

a message from the queue if one is available, null if unable to peek

Annotations

@Override

relaxedPoll back to summary

relaxedPoll	back to summary
public T relaxedPoll() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPoll. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPoll. Called from the consumer thread subject to the restrictions appropriate to the implementation. As opposed to `Queue#poll()` this method may return `null` without the queue being empty. Returns:T a message from the queue if one is available, `null` if unable to poll Annotations @Override

public T relaxedPoll()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPoll.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.relaxedPoll.

Called from the consumer thread subject to the restrictions appropriate to the implementation. As opposed to Queue#poll() this method may return null without the queue being empty.

Returns:T

a message from the queue if one is available, null if unable to poll

Annotations

@Override

size back to summary

size	back to summary
public synchronized int size() Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size. Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size. This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value. For some implementations this method may be O(n) rather than O(1). Returns:int number of messages in the queue, between 0 and `Integer#MAX_VALUE` but less or equals to capacity (if bounded). Annotations @Override

public synchronized int size()

Implements io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size.

Doc from io.netty5.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size.

This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value. For some implementations this method may be O(n) rather than O(1).

Returns:int

number of messages in the queue, between 0 and Integer#MAX_VALUE but less or equals to capacity (if bounded).

Annotations

@Override

Modifier and Type	Field and Description
private final Recycler.LocalPool<T>	localPool
private volatile int	state
private static final int	STATE_AVAILABLE
private static final int	STATE_CLAIMED
private static final AtomicIntegerFieldUpdater<Recycler.DefaultHandle<?>>	STATE_UPDATER
private T	value

Modifier and Type	Method and Description
pack-priv boolean	availableToClaim()
pack-priv T	get()
public void	recycle(Object object) Implements io.netty5.util.internal.ObjectPool.Handle.recycle. Recycle the `Object` if possible and so make it ready to be reused.
pack-priv void	set(T value)
pack-priv void	toAvailable()

Modifier and Type	Field and Description
private volatile MessagePassingQueue<Recycler.DefaultHandle<T>>	pooledHandles
private int	ratioCounter
private final int	ratioInterval

Modifier and Type	Method and Description
pack-priv Recycler.DefaultHandle<T>	claim()
pack-priv Recycler.DefaultHandle<T>	newHandle()
pack-priv void	release(Recycler.DefaultHandle<T> handle)

public abstract Class Recycler<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class Recycler.BlockingMessageQueue<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class Recycler.DefaultHandle<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface Recycler.Handle<T>

Method Summary

private final Class Recycler.LocalPool<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail