org.oddjob.scheduling

Class ExecutorServiceThrottle

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.oddjob.scheduling.ExecutorServiceThrottle

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class ExecutorServiceThrottle
extends java.util.concurrent.AbstractExecutorService

An ExecutorService that limits the number of Runnables running.

Work will be executed in the order in which it was submitted.

Author:

rob

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceThrottle(java.util.concurrent.ExecutorService delegate, int threads)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	execute(java.lang.Runnable command)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()
java.lang.String	toString()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorServiceThrottle

public ExecutorServiceThrottle(java.util.concurrent.ExecutorService delegate,
                               int threads)

Method Detail

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

shutdown

public void shutdown()

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

execute

public void execute(java.lang.Runnable command)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object