Package org.cometd.benchmark

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 org.eclipse.jetty.util.BlockingArrayQueue

        DEFAULT_CAPACITY, DEFAULT_GROWTH

      • Fields inherited from class java.util.AbstractList

        modCount

    • 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 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 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