org.jboss.threads

Class LimitedExecutor

java.lang.Object

org.jboss.threads.LimitedExecutor

All Implemented Interfaces:

java.util.concurrent.Executor

public class LimitedExecutor
extends java.lang.Object
implements java.util.concurrent.Executor

An executor for long-running tasks which limits the total concurrency over a delegate thread pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	LimitedExecutor.Runner

Field Summary

Fields

Modifier and Type	Field and Description
private int	concurrencyLimit
private java.util.concurrent.Executor	executor
private java.lang.Thread.UncaughtExceptionHandler	handler
private LimitedExecutor.Runner	runner

Constructor Summary

Constructors

Constructor and Description
LimitedExecutor(java.util.concurrent.Executor executor, int concurrencyLimit)
LimitedExecutor(java.util.concurrent.Executor executor, java.lang.Thread.UncaughtExceptionHandler handler, int concurrencyLimit)

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

executor

private final java.util.concurrent.Executor executor

handler

private final java.lang.Thread.UncaughtExceptionHandler handler

concurrencyLimit

private final int concurrencyLimit

runner

private final LimitedExecutor.Runner runner

Constructor Detail

LimitedExecutor

public LimitedExecutor(java.util.concurrent.Executor executor,
                       java.lang.Thread.UncaughtExceptionHandler handler,
                       int concurrencyLimit)

LimitedExecutor

public LimitedExecutor(java.util.concurrent.Executor executor,
                       int concurrencyLimit)

Method Detail

execute

public void execute(java.lang.Runnable command)
             throws java.util.concurrent.RejectedExecutionException

Specified by:

execute in interface java.util.concurrent.Executor

Throws:

java.util.concurrent.RejectedExecutionException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object