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

    Modifier and Type Method Description
    void clear()  
    boolean offer​(java.lang.Runnable job)  
    java.lang.Runnable poll()  
    java.lang.Runnable poll​(long time, java.util.concurrent.TimeUnit unit)  
    void reset()  
    java.lang.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 java.util.Collection<java.lang.Runnable>
      Specified by:
      clear in interface java.util.List<java.lang.Runnable>
      Overrides:
      clear in class org.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>

    • offer

      public boolean offer​(java.lang.Runnable job)
      Specified by:
      offer in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
      Specified by:
      offer in interface java.util.Queue<java.lang.Runnable>
      Overrides:
      offer in class org.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>

    • poll

      public java.lang.Runnable poll()
      Specified by:
      poll in interface java.util.Queue<java.lang.Runnable>
      Overrides:
      poll in class org.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 interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
      Overrides:
      poll in class org.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 interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
      Overrides:
      take in class org.eclipse.jetty.util.BlockingArrayQueue<java.lang.Runnable>
      Throws:
      java.lang.InterruptedException