Package org.cometd.benchmark
Class MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractList<E>
org.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue
- All Implemented Interfaces:
java.lang.Iterable<java.lang.Runnable>
,java.util.Collection<java.lang.Runnable>
,java.util.concurrent.BlockingQueue<java.lang.Runnable>
,java.util.List<java.lang.Runnable>
,java.util.Queue<java.lang.Runnable>
- Enclosing class:
- MonitoringQueuedThreadPool
public static class MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue
extends org.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
-
Field Summary
Fields inherited from class org.eclipse.jetty.util.BlockingArrayQueue
DEFAULT_CAPACITY, DEFAULT_GROWTH
Fields inherited from class java.util.AbstractList
modCount
-
Constructor Summary
Constructors Constructor Description MonitoringBlockingArrayQueue(int capacity, int growBy)
-
Method Summary
Methods inherited from class org.eclipse.jetty.util.BlockingArrayQueue
add, add, drainTo, drainTo, element, get, getCapacity, getMaxCapacity, iterator, listIterator, offer, peek, put, remainingCapacity, remove, remove, remove, set, size
Methods inherited from class java.util.AbstractList
addAll, equals, hashCode, indexOf, lastIndexOf, listIterator, removeRange, subList
Methods inherited from class java.util.AbstractCollection
addAll, contains, containsAll, isEmpty, removeAll, retainAll, toArray, toArray, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.util.concurrent.BlockingQueue
contains
Methods inherited from interface java.util.Collection
parallelStream, removeIf, stream, toArray
Methods inherited from interface java.lang.Iterable
forEach
Methods inherited from interface java.util.List
addAll, contains, containsAll, isEmpty, removeAll, replaceAll, retainAll, sort, spliterator, toArray, toArray
-
Constructor Details
-
MonitoringBlockingArrayQueue
public MonitoringBlockingArrayQueue(int capacity, int growBy)
-
-
Method Details
-
reset
public void reset() -
clear
public void clear()- Specified by:
clear
in interfacejava.util.Collection<java.lang.Runnable>
- Specified by:
clear
in interfacejava.util.List<java.lang.Runnable>
- Overrides:
clear
in classorg.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
-
offer
public boolean offer(java.lang.Runnable job)- Specified by:
offer
in interfacejava.util.concurrent.BlockingQueue<java.lang.Runnable>
- Specified by:
offer
in interfacejava.util.Queue<java.lang.Runnable>
- Overrides:
offer
in classorg.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
-
poll
public java.lang.Runnable poll()- Specified by:
poll
in interfacejava.util.Queue<java.lang.Runnable>
- Overrides:
poll
in classorg.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
-
poll
public java.lang.Runnable poll(long time, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException- Specified by:
poll
in interfacejava.util.concurrent.BlockingQueue<java.lang.Runnable>
- Overrides:
poll
in classorg.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
- Throws:
java.lang.InterruptedException
-
take
public java.lang.Runnable take() throws java.lang.InterruptedException- Specified by:
take
in interfacejava.util.concurrent.BlockingQueue<java.lang.Runnable>
- Overrides:
take
in classorg.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
- Throws:
java.lang.InterruptedException
-