BoundedExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

com.mchange.v3.concurrent.BoundedExecutorService

All Implemented Interfaces:: AutoCloseable, Executor, ExecutorService

public final class BoundedExecutorService extends AbstractExecutorService

Constructor Summary

Constructors

Constructor

Description

BoundedExecutorService(ExecutorService inner, int blockBound)

BoundedExecutorService(ExecutorService inner, int blockBound, int restartBeneath)
Method Summary

Modifier and Type

Method

Description

boolean

awaitTermination(long timeout, TimeUnit unit)

void

execute(Runnable runnable)

com.mchange.v3.concurrent.BoundedExecutorService.State

getState()

boolean

isShutdown()

boolean

isTerminated()

protected <V> RunnableFuture<V>

newTaskFor(Runnable runnable, V result)

protected <V> RunnableFuture<V>

newTaskFor(Callable<V> callable)

void

shutdown()

List<Runnable>

shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.ExecutorService
close

Constructor Details
- BoundedExecutorService
  
  public BoundedExecutorService(ExecutorService inner, int blockBound, int restartBeneath)
- BoundedExecutorService
  
  public BoundedExecutorService(ExecutorService inner, int blockBound)
Method Details
- getState
  
  public com.mchange.v3.concurrent.BoundedExecutorService.State getState()
- isShutdown
  
  public boolean isShutdown()
- isTerminated
  
  public boolean isTerminated()
- shutdown
  
  public void shutdown()
- shutdownNow
  
  public List<Runnable> shutdownNow()
- awaitTermination
  
  public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
  
  Throws:
  
  InterruptedException
- execute
  
  public void execute(Runnable runnable)
- newTaskFor
  
  protected <V> RunnableFuture<V> newTaskFor(Callable<V> callable)
  
  Overrides:
  
  newTaskFor in class AbstractExecutorService
- newTaskFor
  
  protected <V> RunnableFuture<V> newTaskFor(Runnable runnable, V result)
  
  Overrides:
  
  newTaskFor in class AbstractExecutorService