Package org.openspaces.pu.container.jee.jetty.holder

Class SharedThreadPool

java.lang.Object
org.openspaces.pu.container.jee.jetty.holder.SharedThreadPool
All Implemented Interfaces:
Executor, org.eclipse.jetty.util.component.LifeCycle, org.eclipse.jetty.util.thread.ThreadPool
public class SharedThreadPool extends Object implements org.eclipse.jetty.util.thread.ThreadPool, org.eclipse.jetty.util.component.LifeCycle
A Jetty ThreadPool that shares a single instance of a thread pool. The first thread pool passed will win and be used.
Author:
kimchy

  • Constructor Details

    • SharedThreadPool

      public SharedThreadPool(org.eclipse.jetty.util.thread.ThreadPool threadPool)

  • Method Details

    • execute

      public void execute(Runnable command)
      Specified by:
      execute in interface Executor

    • join

      public void join() throws InterruptedException
      Specified by:
      join in interface org.eclipse.jetty.util.thread.ThreadPool
      Throws:
      InterruptedException

    • getThreads

      public int getThreads()
      Specified by:
      getThreads in interface org.eclipse.jetty.util.thread.ThreadPool

    • getIdleThreads

      public int getIdleThreads()
      Specified by:
      getIdleThreads in interface org.eclipse.jetty.util.thread.ThreadPool

    • isLowOnThreads

      public boolean isLowOnThreads()
      Specified by:
      isLowOnThreads in interface org.eclipse.jetty.util.thread.ThreadPool

    • start

      public void start() throws Exception
      Specified by:
      start in interface org.eclipse.jetty.util.component.LifeCycle
      Throws:
      Exception

    • stop

      public void stop() throws Exception
      Specified by:
      stop in interface org.eclipse.jetty.util.component.LifeCycle
      Throws:
      Exception

    • isRunning

      public boolean isRunning()
      Specified by:
      isRunning in interface org.eclipse.jetty.util.component.LifeCycle

    • isStarted

      public boolean isStarted()
      Specified by:
      isStarted in interface org.eclipse.jetty.util.component.LifeCycle

    • isStarting

      public boolean isStarting()
      Specified by:
      isStarting in interface org.eclipse.jetty.util.component.LifeCycle

    • isStopping

      public boolean isStopping()
      Specified by:
      isStopping in interface org.eclipse.jetty.util.component.LifeCycle

    • isStopped

      public boolean isStopped()
      Specified by:
      isStopped in interface org.eclipse.jetty.util.component.LifeCycle

    • isFailed

      public boolean isFailed()
      Specified by:
      isFailed in interface org.eclipse.jetty.util.component.LifeCycle

    • addEventListener

      public boolean addEventListener(EventListener eventListener)
      Specified by:
      addEventListener in interface org.eclipse.jetty.util.component.LifeCycle

    • removeEventListener

      public boolean removeEventListener(EventListener eventListener)
      Specified by:
      removeEventListener in interface org.eclipse.jetty.util.component.LifeCycle

    • toString

      public String toString()
      Overrides:
      toString in class Object