Package org.openrefine.util.threads

Class ThreadPoolExecutorAdapter

java.lang.Object

org.openrefine.util.threads.ThreadPoolExecutorAdapter

All Implemented Interfaces:

Executor, org.eclipse.jetty.util.component.LifeCycle, org.eclipse.jetty.util.thread.ThreadPool

public class ThreadPoolExecutorAdapter
extends Object
implements org.eclipse.jetty.util.thread.ThreadPool, org.eclipse.jetty.util.component.LifeCycle

Jetty ThreadPool that bridges requests to a ThreadPoolExecutor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

org.eclipse.jetty.util.component.LifeCycle.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ThreadPool

org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool

Constructor Summary

Constructors

Constructor	Description
ThreadPoolExecutorAdapter(ThreadPoolExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	addLifeCycleListener(org.eclipse.jetty.util.component.LifeCycle.Listener listener)
void	execute(Runnable job)
int	getIdleThreads()
int	getThreads()
boolean	isFailed()
boolean	isLowOnThreads()
boolean	isRunning()
boolean	isStarted()
boolean	isStarting()
boolean	isStopped()
boolean	isStopping()
void	join()
void	removeLifeCycleListener(org.eclipse.jetty.util.component.LifeCycle.Listener listener)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadPoolExecutorAdapter

public ThreadPoolExecutorAdapter(ThreadPoolExecutor executor)

Method Detail

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

getIdleThreads

public int getIdleThreads()

Specified by:

getIdleThreads in interface org.eclipse.jetty.util.thread.ThreadPool

getThreads

public int getThreads()

Specified by:

getThreads in interface org.eclipse.jetty.util.thread.ThreadPool

isLowOnThreads

public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface org.eclipse.jetty.util.thread.ThreadPool

join

public void join()
          throws InterruptedException

Specified by:

join in interface org.eclipse.jetty.util.thread.ThreadPool

Throws:

InterruptedException

isFailed

public boolean isFailed()

Specified by:

isFailed in interface org.eclipse.jetty.util.component.LifeCycle

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

isStopped

public boolean isStopped()

Specified by:

isStopped in interface org.eclipse.jetty.util.component.LifeCycle

isStopping

public boolean isStopping()

Specified by:

isStopping in interface org.eclipse.jetty.util.component.LifeCycle

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

addLifeCycleListener

public void addLifeCycleListener(org.eclipse.jetty.util.component.LifeCycle.Listener listener)

Specified by:

addLifeCycleListener in interface org.eclipse.jetty.util.component.LifeCycle

removeLifeCycleListener

public void removeLifeCycleListener(org.eclipse.jetty.util.component.LifeCycle.Listener listener)

Specified by:

removeLifeCycleListener in interface org.eclipse.jetty.util.component.LifeCycle