ThreadPoolExecutor (Apache Tomcat 7.0.67 API Documentation)

java.lang.Object
- java.util.concurrent.AbstractExecutorService
- - java.util.concurrent.ThreadPoolExecutor
  - - org.apache.tomcat.util.threads.ThreadPoolExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService
```
public class ThreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor
```
Same as a java.util.concurrent.ThreadPoolExecutor but implements a much more efficient getSubmittedCount() method, to be used to properly handle the work queue. If a RejectedExecutionHandler is not specified a default one will be configured and that one will always throw a RejectedExecutionException

Author:

fhanik

Nested Class Summary
- Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
  java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields
Modifier and Type Field and Description

protected static StringManager sm
The string manager for this package.

Fields
Modifier and Type	Field and Description
`protected static StringManager`	`sm` The string manager for this package.

Constructor Summary

Constructors
Constructor and Description
`ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)`
`ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler)`
`ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory)`
`ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected void`	`afterExecute(java.lang.Runnable r, java.lang.Throwable t)`
`void`	`contextStopping()`
`protected boolean`	`currentThreadShouldBeStopped()`
`void`	`execute(java.lang.Runnable command)`
`void`	`execute(java.lang.Runnable command, long timeout, java.util.concurrent.TimeUnit unit)` Executes the given command at some time in the future.
`int`	`getSubmittedCount()`
`long`	`getThreadRenewalDelay()`
`void`	`setThreadRenewalDelay(long threadRenewalDelay)`
`protected void`	`stopCurrentThreadIfNeeded()` If the current thread was started before the last time when a context was stopped, an exception is thrown so that the current thread is stopped.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor
allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail
- sm
```
protected static final StringManager sm
```
  The string manager for this package.

Constructor Detail

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  java.util.concurrent.TimeUnit unit,
                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                  java.util.concurrent.RejectedExecutionHandler handler)

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  java.util.concurrent.TimeUnit unit,
                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                  java.util.concurrent.ThreadFactory threadFactory,
                  java.util.concurrent.RejectedExecutionHandler handler)

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  java.util.concurrent.TimeUnit unit,
                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                  java.util.concurrent.ThreadFactory threadFactory)

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  java.util.concurrent.TimeUnit unit,
                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)

Method Detail
- getThreadRenewalDelay
```
public long getThreadRenewalDelay()
```
- setThreadRenewalDelay
```
public void setThreadRenewalDelay(long threadRenewalDelay)
```
- afterExecute
```
protected void afterExecute(java.lang.Runnable r,
                java.lang.Throwable t)
```
  Overrides:
  
  afterExecute in class java.util.concurrent.ThreadPoolExecutor
- stopCurrentThreadIfNeeded
```
protected void stopCurrentThreadIfNeeded()
```
  If the current thread was started before the last time when a context was stopped, an exception is thrown so that the current thread is stopped.
- currentThreadShouldBeStopped
```
protected boolean currentThreadShouldBeStopped()
```
- getSubmittedCount
```
public int getSubmittedCount()
```
- execute
```
public void execute(java.lang.Runnable command)
```
  Specified by:
  
  execute in interface java.util.concurrent.Executor
  
  Overrides:
  
  execute in class java.util.concurrent.ThreadPoolExecutor
- execute
```
public void execute(java.lang.Runnable command,
           long timeout,
           java.util.concurrent.TimeUnit unit)
```
  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. If no threads are available, it will be added to the work queue. If the work queue is full, the system will wait for the specified time and it throw a RejectedExecutionException if the queue is still full after that.
  
  Parameters:
  command - the runnable task
  
  Throws:
  
  java.util.concurrent.RejectedExecutionException - if this task cannot be accepted for execution - the queue is full
  
  java.lang.NullPointerException - if command or unit is null
- contextStopping
```
public void contextStopping()
```

Class ThreadPoolExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

Methods inherited from class java.util.concurrent.AbstractExecutorService

Methods inherited from class java.lang.Object

Field Detail

sm

Constructor Detail

ThreadPoolExecutor

ThreadPoolExecutor

ThreadPoolExecutor

ThreadPoolExecutor

Method Detail

getThreadRenewalDelay

setThreadRenewalDelay

afterExecute

stopCurrentThreadIfNeeded

currentThreadShouldBeStopped

getSubmittedCount

execute

execute

contextStopping