Package jetbrains.buildServer.util.executors

Class ScalingThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

jetbrains.buildServer.util.executors.TeamCityThreadPoolExecutor

jetbrains.buildServer.util.executors.ScalingThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, ExecutorServiceEx

Direct Known Subclasses:

CommonExecutorService, MockScheduledExecutorService

public class ScalingThreadPoolExecutor
extends TeamCityThreadPoolExecutor

Thread pool executor with minimum and maximum threads and maximum capacity of input queue.

Nested Class Summary

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

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor	Description
ScalingThreadPoolExecutor(int corePoolSize, int maximumPoolSize, int maximumQueueCapacity, long keepAliveTime, TimeUnit unit, NamedThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
int	getMaxQueueCapacity()
jetbrains.buildServer.util.executors.ScalingThreadPoolExecutor.ScalingQueue<Runnable>	getQueue()
long	getRejectsCount()

Methods inherited from class jetbrains.buildServer.util.executors.TeamCityThreadPoolExecutor

afterExecute, beforeExecute, getName, getQueuedTasksCount, isPaused, newTaskFor, newTaskFor, pause, resume, setPoolSize, shutdown

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdownNow, submit, submit, submit

Methods inherited from interface jetbrains.buildServer.util.executors.ExecutorServiceEx

getActiveCount

Constructor Detail

ScalingThreadPoolExecutor

public ScalingThreadPoolExecutor(int corePoolSize,
                                 int maximumPoolSize,
                                 int maximumQueueCapacity,
                                 long keepAliveTime,
                                 @NotNull
                                 TimeUnit unit,
                                 @NotNull
                                 NamedThreadFactory threadFactory)

Method Detail

getQueue

public final jetbrains.buildServer.util.executors.ScalingThreadPoolExecutor.ScalingQueue<Runnable> getQueue()

Overrides:

getQueue in class ThreadPoolExecutor

getMaxQueueCapacity

public int getMaxQueueCapacity()

getRejectsCount

public long getRejectsCount()