Class ReservedThreadExecutor

java.lang.Object
org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.thread.ReservedThreadExecutor
All Implemented Interfaces:
Executor, Dumpable, LifeCycle, TryExecutor
@ManagedObject("A pool for reserved threads") public class ReservedThreadExecutor extends AbstractLifeCycle implements TryExecutor, Dumpable

A TryExecutor using pre-allocated/reserved threads from an external Executor.

Calls to tryExecute(Runnable) on ReservedThreadExecutor will either succeed with a reserved thread immediately being assigned the task, or fail if no reserved thread is available.

Threads are reserved lazily, with new reserved threads being allocated from the external Executor passed to the constructor. Whenever 1 or more reserved threads have been idle for more than getIdleTimeoutMs() then one reserved thread will return to the external Executor.

  • Field Details

  • Constructor Details

    • ReservedThreadExecutor

      public ReservedThreadExecutor(Executor executor, int capacity)
      Parameters:
      executor - The executor to use to obtain threads
      capacity - The number of threads to preallocate. If less than 0 then capacity is calculated based on a heuristic from the number of available processors and thread pool size.

  • Method Details

    • reservedThreads

      private static int reservedThreads(Executor executor, int capacity)
      Parameters:
      executor - The executor to use to obtain threads
      capacity - The number of threads to preallocate, If less than 0 then capacity is calculated based on a heuristic from the number of available processors and thread pool size.
      Returns:
      the number of reserved threads that would be used by a ReservedThreadExecutor constructed with these arguments.

    • getExecutor

      public Executor getExecutor()

    • getCapacity

      @ManagedAttribute(value="max number of reserved threads", readonly=true) public int getCapacity()
      Returns:
      the maximum number of reserved threads

    • getAvailable

      @ManagedAttribute(value="available reserved threads", readonly=true) public int getAvailable()
      Returns:
      the number of threads available to tryExecute(Runnable)

    • getPending

      @ManagedAttribute(value="pending reserved threads", readonly=true) public int getPending()

    • getIdleTimeoutMs

      @ManagedAttribute(value="idle timeout in ms", readonly=true) public long getIdleTimeoutMs()

    • setIdleTimeout

      public void setIdleTimeout(long idleTime, TimeUnit idleTimeUnit)
      Set the idle timeout for shrinking the reserved thread pool
      Parameters:
      idleTime - Time to wait before shrinking, or 0 for default timeout.
      idleTimeUnit - Time units for idle timeout

    • doStart

      public void doStart() throws Exception
      Overrides:
      doStart in class AbstractLifeCycle
      Throws:
      Exception

    • doStop

      public void doStop() throws Exception
      Overrides:
      doStop in class AbstractLifeCycle
      Throws:
      Exception

    • execute

      public void execute(Runnable task) throws RejectedExecutionException
      Specified by:
      execute in interface Executor
      Specified by:
      execute in interface TryExecutor
      Throws:
      RejectedExecutionException

    • tryExecute

      public boolean tryExecute(Runnable task)

      Executes the given task if and only if a reserved thread is available.

      Specified by:
      tryExecute in interface TryExecutor
      Parameters:
      task - the task to run
      Returns:
      true if and only if a reserved thread was available and has been assigned the task to run.

    • startReservedThread

      private void startReservedThread()

    • dump

      public void dump(Appendable out, String indent) throws IOException
      Description copied from interface: Dumpable
      Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.
      Specified by:
      dump in interface Dumpable
      Parameters:
      out - The appendable to dump to
      indent - The indent to apply after any new lines.
      Throws:
      IOException - if unable to write to Appendable

    • toString

      public String toString()
      Overrides:
      toString in class AbstractLifeCycle