Modifier and Type	Class and Description
private static interface	BoundedExecutorService.DelayedTaskSettable<V>
private class	BoundedExecutorService.PermitAcquiringCallable<V>
private class	BoundedExecutorService.PermitAcquiringRunnable<V>
private class	BoundedExecutorService.ReleasingFutureTask<V>
pack-priv static enum	BoundedExecutorService.State

Modifier and Type	Field and Description
pack-priv final int	blockBound
pack-priv final ExecutorService	inner
pack-priv static final MLogger	logger
pack-priv int	permits
pack-priv final int	restartBeneath
pack-priv BoundedExecutorService.State	state
pack-priv Map<Thread, Runnable>	waiters

Access	Constructor and Description
public	BoundedExecutorService(ExecutorService inner, int blockBound, int restartBeneath)
public	BoundedExecutorService(ExecutorService inner, int blockBound)

Method Summary

Modifier and Type	Method and Description
private synchronized void	acquirePermit(Runnable task)
public synchronized boolean	awaitTermination(long the maximum time to wait timeout, TimeUnit the time unit of the timeout argument unit) Implements java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
private void	doUpdateState(BoundedExecutorService.State newState)
public void	execute(Runnable the runnable task runnable) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.
public synchronized BoundedExecutorService.State	getState()
public synchronized boolean	isShutdown() Implements java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down.
public synchronized boolean	isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down.
protected <V> RunnableFuture<V>	newTaskFor(Callable<V> the callable task being wrapped callable) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given callable task.
protected <V> RunnableFuture<V>	newTaskFor(Runnable the runnable task being wrapped runnable, V the default value for the returned future result) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given runnable and default value.
private synchronized void	releasePermit()
private boolean	shouldWait()
public synchronized void	shutdown() Implements java.util.concurrent.ExecutorService.shutdown. Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
public synchronized List<Runnable>	shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
private void	updateState(BoundedExecutorService.State newState)

Inherited from java.util.concurrent.AbstractExecutorService:: invokeAll invokeAll invokeAny invokeAny submit submit submit

Field Detail

blockBound	back to summary
pack-priv final int blockBound

inner	back to summary
pack-priv final ExecutorService inner

logger	back to summary
pack-priv static final MLogger logger

permits	back to summary
pack-priv int permits

restartBeneath	back to summary
pack-priv final int restartBeneath

state	back to summary
pack-priv BoundedExecutorService.State state

waiters	back to summary
pack-priv Map<Thread, Runnable> waiters

Constructor Detail

BoundedExecutorService	back to summary
public BoundedExecutorService(ExecutorService inner, int blockBound, int restartBeneath)

BoundedExecutorService	back to summary
public BoundedExecutorService(ExecutorService inner, int blockBound)

Method Detail

acquirePermit	back to summary
private synchronized void acquirePermit(Runnable task)

awaitTermination back to summary

awaitTermination	back to summary
public synchronized boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException Implements java.util.concurrent.ExecutorService.awaitTermination. Doc from java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first. Parameters timeout:long the maximum time to wait unit:TimeUnit the time unit of the timeout argument Returns:boolean `true` if this executor terminated and `false` if the timeout elapsed before termination Exceptions InterruptedException: if interrupted while waiting

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

Implements java.util.concurrent.ExecutorService.awaitTermination.

Doc from java.util.concurrent.ExecutorService.awaitTermination.

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Parameters

timeout:long: the maximum time to wait
unit:TimeUnit: the time unit of the timeout argument

Returns:boolean

true if this executor terminated and false if the timeout elapsed before termination

Exceptions

InterruptedException:: if interrupted while waiting

doUpdateState	back to summary
private void doUpdateState(BoundedExecutorService.State newState)

execute back to summary

execute	back to summary
public void execute(Runnable runnable) Implements java.util.concurrent.Executor.execute. Doc from java.util.concurrent.Executor.execute. Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the `Executor` implementation. Parameters runnable:Runnable the runnable task

public void execute(Runnable runnable)

Implements java.util.concurrent.Executor.execute.

Doc from java.util.concurrent.Executor.execute.

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation.

Parameters

runnable:Runnable: the runnable task

getState	back to summary
public synchronized BoundedExecutorService.State getState()

isShutdown back to summary

isShutdown	back to summary
public synchronized boolean isShutdown() Implements java.util.concurrent.ExecutorService.isShutdown. Doc from java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down. Returns:boolean `true` if this executor has been shut down

public synchronized boolean isShutdown()

Implements java.util.concurrent.ExecutorService.isShutdown.

Doc from java.util.concurrent.ExecutorService.isShutdown.

Returns true if this executor has been shut down.

Returns:boolean: true if this executor has been shut down

isTerminated back to summary

isTerminated	back to summary
public synchronized boolean isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Doc from java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down. Note that `isTerminated` is never `true` unless either `shutdown` or `shutdownNow` was called first. Returns:boolean `true` if all tasks have completed following shut down

public synchronized boolean isTerminated()

Implements java.util.concurrent.ExecutorService.isTerminated.

Doc from java.util.concurrent.ExecutorService.isTerminated.

Returns true if all tasks have completed following shut down. Note that isTerminated is never true unless either shutdown or shutdownNow was called first.

Returns:boolean: true if all tasks have completed following shut down

newTaskFor back to summary

newTaskFor	back to summary
protected <V> RunnableFuture<V> newTaskFor(Callable<V> callable) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Doc from java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given callable task. Parameters <V> the type of the callable's result callable:Callable<V> the callable task being wrapped Returns:RunnableFuture<V> a `RunnableFuture` which, when run, will call the underlying callable and which, as a `Future`, will yield the callable's result as its result and provide for cancellation of the underlying task

protected <V> RunnableFuture<V> newTaskFor(Callable<V> callable)

Overrides java.util.concurrent.AbstractExecutorService.newTaskFor.

Doc from java.util.concurrent.AbstractExecutorService.newTaskFor.

Returns a RunnableFuture for the given callable task.

Parameters

<V>: the type of the callable's result
callable:Callable<V>: the callable task being wrapped

Returns:RunnableFuture<V>

a RunnableFuture which, when run, will call the underlying callable and which, as a Future, will yield the callable's result as its result and provide for cancellation of the underlying task

newTaskFor back to summary

newTaskFor	back to summary
protected <V> RunnableFuture<V> newTaskFor(Runnable runnable, V result) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Doc from java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given runnable and default value. Parameters <V> the type of the given value runnable:Runnable the runnable task being wrapped result:V the default value for the returned future Returns:RunnableFuture<V> a `RunnableFuture` which, when run, will run the underlying runnable and which, as a `Future`, will yield the given value as its result and provide for cancellation of the underlying task

protected <V> RunnableFuture<V> newTaskFor(Runnable runnable, V result)

Overrides java.util.concurrent.AbstractExecutorService.newTaskFor.

Doc from java.util.concurrent.AbstractExecutorService.newTaskFor.

Returns a RunnableFuture for the given runnable and default value.

Parameters

<V>: the type of the given value
runnable:Runnable: the runnable task being wrapped
result:V: the default value for the returned future

Returns:RunnableFuture<V>

a RunnableFuture which, when run, will run the underlying runnable and which, as a Future, will yield the given value as its result and provide for cancellation of the underlying task

releasePermit	back to summary
private synchronized void releasePermit()

shouldWait	back to summary
private boolean shouldWait()

shutdown back to summary

shutdown	back to summary
public synchronized void shutdown() Implements java.util.concurrent.ExecutorService.shutdown. Doc from java.util.concurrent.ExecutorService.shutdown. Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down. This method does not wait for previously submitted tasks to complete execution. Use `awaitTermination` to do that.

public synchronized void shutdown()

Implements java.util.concurrent.ExecutorService.shutdown.

Doc from java.util.concurrent.ExecutorService.shutdown.

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.

This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.

shutdownNow back to summary

shutdownNow	back to summary
public synchronized List<Runnable> shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Doc from java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution. This method does not wait for actively executing tasks to terminate. Use `awaitTermination` to do that. There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via `Thread#interrupt`, so any task that fails to respond to interrupts may never terminate. Returns:List<Runnable> list of tasks that never commenced execution

public synchronized List<Runnable> shutdownNow()

Implements java.util.concurrent.ExecutorService.shutdownNow.

Doc from java.util.concurrent.ExecutorService.shutdownNow.

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

This method does not wait for actively executing tasks to terminate. Use awaitTermination to do that.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread#interrupt, so any task that fails to respond to interrupts may never terminate.

Returns:List<Runnable>: list of tasks that never commenced execution

updateState	back to summary
private void updateState(BoundedExecutorService.State newState)

com.mchange.v3.concurrent back to summary

private Interface BoundedExecutorService.DelayedTaskSettable<V>

Known Direct Implementers: com.mchange.v3.concurrent.BoundedExecutorService.PermitAcquiringCallable, com.mchange.v3.concurrent.BoundedExecutorService.PermitAcquiringRunnable

Method Summary

Modifier and Type	Method and Description
public void	setTask(BoundedExecutorService.ReleasingFutureTask<V> task)

Method Detail

setTask	back to summary
public void setTask(BoundedExecutorService.ReleasingFutureTask<V> task)

com.mchange.v3.concurrent back to summary

private final Class BoundedExecutorService.PermitAcquiringCallable<V>

Class Inheritance

extends Object
implements Callable<V>, BoundedExecutorService.DelayedTaskSettable<V>

java.lang.Object
com.mchange.v3.concurrent.BoundedExecutorService.PermitAcquiringCallable

All Implemented Interfaces

com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable, java.util.concurrent.Callable

Field Summary

Modifier and Type	Field and Description
pack-priv Callable<V>	callable
pack-priv BoundedExecutorService.ReleasingFutureTask<V>	task

Constructor Summary

Access	Constructor and Description
pack-priv	PermitAcquiringCallable(Callable<V> callable)

Method Summary

Modifier and Type	Method and Description
public V	call() Implements java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so.
public void	setTask(BoundedExecutorService.ReleasingFutureTask<V> task) Implements com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable.setTask.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

callable	back to summary
pack-priv Callable<V> callable

task	back to summary
pack-priv BoundedExecutorService.ReleasingFutureTask<V> task

Constructor Detail

PermitAcquiringCallable	back to summary
pack-priv PermitAcquiringCallable(Callable<V> callable)

Method Detail

call	back to summary
public V call() throws Exception Implements java.util.concurrent.Callable.call. Doc from java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so. Returns:V computed result Exceptions Exception: if unable to compute a result

call

back to summary

public V call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:V

computed result

Exceptions

Exception:: if unable to compute a result

setTask	back to summary
public void setTask(BoundedExecutorService.ReleasingFutureTask<V> task) Implements com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable.setTask.

com.mchange.v3.concurrent back to summary

private final Class BoundedExecutorService.PermitAcquiringRunnable<V>

Class Inheritance

extends Object
implements Runnable, BoundedExecutorService.DelayedTaskSettable<V>

java.lang.Object
com.mchange.v3.concurrent.BoundedExecutorService.PermitAcquiringRunnable

All Implemented Interfaces

com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable, java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv Runnable	runnable
pack-priv BoundedExecutorService.ReleasingFutureTask<V>	task

Constructor Summary

Access	Constructor and Description
pack-priv	PermitAcquiringRunnable(Runnable runnable)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public void	setTask(BoundedExecutorService.ReleasingFutureTask<V> task) Implements com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable.setTask.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

runnable	back to summary
pack-priv Runnable runnable

task	back to summary
pack-priv BoundedExecutorService.ReleasingFutureTask<V> task

Constructor Detail

PermitAcquiringRunnable	back to summary
pack-priv PermitAcquiringRunnable(Runnable runnable)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation.

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

setTask	back to summary
public void setTask(BoundedExecutorService.ReleasingFutureTask<V> task) Implements com.mchange.v3.concurrent.BoundedExecutorService.DelayedTaskSettable.setTask.

com.mchange.v3.concurrent back to summary

private final Class BoundedExecutorService.ReleasingFutureTask<V>

Class Inheritance

extends FutureTask<V>

java.lang.Object
java.util.concurrent.FutureTask
com.mchange.v3.concurrent.BoundedExecutorService.ReleasingFutureTask

Constructor Summary

Access	Constructor and Description
pack-priv	ReleasingFutureTask(BoundedExecutorService.PermitAcquiringCallable<V> callable)
pack-priv	ReleasingFutureTask(BoundedExecutorService.PermitAcquiringRunnable<V> runnable, V result)

Method Summary

Modifier and Type	Method and Description
protected void	done() Overrides java.util.concurrent.FutureTask.done. Protected method invoked when this task transitions to state `isDone` (whether normally or via cancellation).

Inherited from java.util.concurrent.FutureTask:: cancel exceptionNow get get isCancelled isDone resultNow run runAndReset set setException state toString

Constructor Detail

ReleasingFutureTask	back to summary
pack-priv ReleasingFutureTask(BoundedExecutorService.PermitAcquiringCallable<V> callable)

ReleasingFutureTask	back to summary
pack-priv ReleasingFutureTask(BoundedExecutorService.PermitAcquiringRunnable<V> runnable, V result)

Method Detail

done back to summary

done	back to summary
protected void done() Overrides java.util.concurrent.FutureTask.done. Doc from java.util.concurrent.FutureTask.done. Protected method invoked when this task transitions to state `isDone` (whether normally or via cancellation). The default implementation does nothing. Subclasses may override this method to invoke completion callbacks or perform bookkeeping. Note that you can query status inside the implementation of this method to determine whether this task has been cancelled.

protected void done()

Overrides java.util.concurrent.FutureTask.done.

Doc from java.util.concurrent.FutureTask.done.

Protected method invoked when this task transitions to state isDone (whether normally or via cancellation). The default implementation does nothing. Subclasses may override this method to invoke completion callbacks or perform bookkeeping. Note that you can query status inside the implementation of this method to determine whether this task has been cancelled.

com.mchange.v3.concurrent back to summary

pack-priv final Enum BoundedExecutorService.State

Class Inheritance

extends Enum<BoundedExecutorService.State>

java.lang.Object
java.lang.Enum
com.mchange.v3.concurrent.BoundedExecutorService.State

Field Summary

Modifier and Type	Field and Description
public static final BoundedExecutorService.State	ACCEPTING
public static final BoundedExecutorService.State	SATURATED
public static final BoundedExecutorService.State	SHUTDOWN
public static final BoundedExecutorService.State	SHUTDOWN_NOW
public static final BoundedExecutorService.State	UNWINDING

Constructor Summary

Access	Constructor and Description
private	State()

Method Summary

Modifier and Type	Method and Description
public static BoundedExecutorService.State	valueOf(String name)
public static BoundedExecutorService.State[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

ACCEPTING	back to summary
public static final BoundedExecutorService.State ACCEPTING

SATURATED	back to summary
public static final BoundedExecutorService.State SATURATED

SHUTDOWN	back to summary
public static final BoundedExecutorService.State SHUTDOWN

SHUTDOWN_NOW	back to summary
public static final BoundedExecutorService.State SHUTDOWN_NOW

UNWINDING	back to summary
public static final BoundedExecutorService.State UNWINDING

Constructor Detail

State	back to summary
private State()

Method Detail

valueOf	back to summary
public static BoundedExecutorService.State valueOf(String name)

values	back to summary
public static BoundedExecutorService.State[] values()

public final Class BoundedExecutorService

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Interface BoundedExecutorService.DelayedTaskSettable<V>

Method Summary

Method Detail

private final Class BoundedExecutorService.PermitAcquiringCallable<V>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class BoundedExecutorService.PermitAcquiringRunnable<V>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class BoundedExecutorService.ReleasingFutureTask<V>

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Enum BoundedExecutorService.State

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail