Class 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 java.util.AbstractList

        modCount
      • Fields inherited from class org.eclipse.jetty.util.BlockingArrayQueue

        DEFAULT_CAPACITY, DEFAULT_GROWTH
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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 java.util.AbstractCollection

        addAll, contains, containsAll, isEmpty, removeAll, retainAll, toArray, toArray, toString
      • Methods inherited from class java.util.AbstractList

        addAll, equals, hashCode, indexOf, lastIndexOf, listIterator, removeRange, subList
      • 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 interface java.util.concurrent.BlockingQueue

        contains
      • Methods inherited from interface java.util.Collection

        addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, 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
      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • MonitoringBlockingArrayQueue

        public MonitoringBlockingArrayQueue​(int capacity,
                                            int growBy)
    • Method Detail

      • 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