protected static class AbstractProtocol.RecycledProcessors<P extends Processor<S>,S> extends ConcurrentLinkedQueue<Processor<S>>
Modifier and Type | Field and Description |
---|---|
protected AtomicInteger |
size |
Constructor and Description |
---|
AbstractProtocol.RecycledProcessors(AbstractProtocol.AbstractConnectionHandler<S,P> handler) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
boolean |
offer(Processor<S> processor) |
Processor<S> |
poll() |
add, addAll, contains, isEmpty, iterator, peek, remove, size, toArray, toArray
element, remove
containsAll, removeAll, retainAll, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
containsAll, equals, hashCode, removeAll, retainAll
protected AtomicInteger size
public AbstractProtocol.RecycledProcessors(AbstractProtocol.AbstractConnectionHandler<S,P> handler)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.