Package org.apache.tomcat.util.threads

Interface RetryableQueue<T>

  • All Superinterfaces:
    java.util.concurrent.BlockingQueue<T>, java.util.Collection<T>, java.lang.Iterable<T>, java.util.Queue<T>
    All Known Implementing Classes:
    TaskQueue
    public interface RetryableQueue<T>
extends java.util.concurrent.BlockingQueue<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      boolean force​(java.lang.Runnable o, long timeout, java.util.concurrent.TimeUnit unit)
      Deprecated.
      Unused.
      boolean force​(T o)
      Used to add a task to the queue if the task has been rejected by the Executor.

      • Methods inherited from interface java.util.concurrent.BlockingQueue

        add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take

      • Methods inherited from interface java.util.Collection

        addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

      • Methods inherited from interface java.lang.Iterable

        forEach

      • Methods inherited from interface java.util.Queue

        element, peek, poll, remove

    • Method Detail

      • force

        boolean force​(T o)
        Used to add a task to the queue if the task has been rejected by the Executor.
        Parameters:
        o - The task to add to the queue
        Returns:
        true if the task was added to the queue, otherwise false

      • force

        @Deprecated
boolean force​(java.lang.Runnable o,
              long timeout,
              java.util.concurrent.TimeUnit unit)
       throws java.lang.InterruptedException
        Deprecated.
        Unused. Will be removed in Tomcat 10.1.x.
        Used to add a task to the queue if the task has been rejected by the Executor.
        Parameters:
        o - The task to add to the queue
        timeout - The timeout to use when adding the task
        unit - The units in which the timeout is expressed
        Returns:
        true if the task was added to the queue, otherwise false
        Throws:
        java.lang.InterruptedException - If the call is interrupted before the timeout expires