Package org.cometd.benchmark

Class MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

All Implemented Interfaces:

Iterable<Runnable>, Collection<Runnable>, BlockingQueue<Runnable>, List<Runnable>, Queue<Runnable>

Enclosing class:

MonitoringQueuedThreadPool

public static class MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue
extends org.eclipse.jetty.util.BlockingArrayQueue<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

Modifier and Type	Method	Description
void	clear()
boolean	offer(Runnable job)
Runnable	poll()
Runnable	poll(long time, TimeUnit unit)
void	reset()
Runnable	take()

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 interface Collection<Runnable>

Specified by:

clear in interface List<Runnable>

Overrides:

clear in class org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

offer

public boolean offer(Runnable job)

Specified by:

offer in interface BlockingQueue<Runnable>

Specified by:

offer in interface Queue<Runnable>

Overrides:

offer in class org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

poll

public Runnable poll()

Specified by:

poll in interface Queue<Runnable>

Overrides:

poll in class org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

poll

public Runnable poll(long time, TimeUnit unit) throws InterruptedException

Specified by:

poll in interface BlockingQueue<Runnable>

Overrides:

poll in class org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

Throws:

InterruptedException

take

public Runnable take() throws InterruptedException

Specified by:

take in interface BlockingQueue<Runnable>

Overrides:

take in class org.eclipse.jetty.util.BlockingArrayQueue<Runnable>

Throws:

InterruptedException