Package net.sf.jstuff.core.concurrent

Class BlockingExecutorService

java.lang.Object

net.sf.jstuff.core.concurrent.BlockingExecutor

net.sf.jstuff.core.concurrent.BlockingExecutorService

All Implemented Interfaces:

Executor, ExecutorService

public class BlockingExecutorService
extends BlockingExecutor
implements ExecutorService

ExecutorService that blocks submission of new tasks if a given maximum number of tasks are already pending.

Author:

Sebastian Thomschke

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	BlockingExecutorService.CallableWrapper<T>

Nested classes/interfaces inherited from class net.sf.jstuff.core.concurrent.BlockingExecutor

BlockingExecutor.RunnableWrapper

Field Summary

Fields inherited from class net.sf.jstuff.core.concurrent.BlockingExecutor

limiter, maxPendingTasks, maxWaitTime, maxWaitTimeUnit, wrapped

Constructor Summary

Constructors

Constructor	Description
BlockingExecutorService(ExecutorService executorService, int maxQueueSize, int maxWaitTime, TimeUnit maxWaitTimeUnit)

Method Summary

Modifier and Type	Method	Description
protected void	aquirePermits(int count)
boolean	awaitTermination(long timeout, TimeUnit unit)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)
protected <T> Collection<Callable<T>>	wrapTasks(Collection<? extends Callable<T>> tasks)

Methods inherited from class net.sf.jstuff.core.concurrent.BlockingExecutor

aquirePermit, execute, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Constructor Details

BlockingExecutorService

public BlockingExecutorService(ExecutorService executorService,
 int maxQueueSize,
 int maxWaitTime,
 TimeUnit maxWaitTimeUnit)

Parameters:

maxWaitTime - max time to wait for a tasks being added to the queue

Method Details

aquirePermits

protected void aquirePermits(int count)
                      throws RejectedExecutionException

Throws:

RejectedExecutionException

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

submit

public <T> Future<T> submit(Callable<T> task)
                     throws RejectedExecutionException

Specified by:

submit in interface ExecutorService

Throws:

RejectedExecutionException

submit

public Future<?> submit(Runnable task)
                 throws RejectedExecutionException

Specified by:

submit in interface ExecutorService

Throws:

RejectedExecutionException

submit

public <T> Future<T> submit(Runnable task,
 T result)
                     throws RejectedExecutionException

Specified by:

submit in interface ExecutorService

Throws:

RejectedExecutionException

wrapTasks

protected <T> Collection<Callable<T>> wrapTasks(Collection<? extends Callable<T>> tasks)
                                         throws RejectedExecutionException

Throws:

RejectedExecutionException