Package jetbrains.buildServer.util.executors

Class TeamCityThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

jetbrains.buildServer.util.executors.TeamCityThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, ExecutorServiceEx

Direct Known Subclasses:

ScalingThreadPoolExecutor

public class TeamCityThreadPoolExecutor
extends ThreadPoolExecutor
implements ExecutorServiceEx

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
TeamCityThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
TeamCityThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable runnable, Throwable throwable)
protected void	beforeExecute(Thread thread, Runnable runnable)
static String	getName(Object task)
int	getQueuedTasksCount()
boolean	isPaused()
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)
void	pause()
void	resume()
void	setPoolSize(int poolSize)	Changes the maximum and core pool sizes of the thread pool.
void	shutdown()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, 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

TeamCityThreadPoolExecutor

public TeamCityThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  @NotNull
                                  TimeUnit unit,
                                  @NotNull
                                  BlockingQueue<Runnable> workQueue,
                                  @NotNull
                                  ThreadFactory threadFactory,
                                  @NotNull
                                  RejectedExecutionHandler handler)

TeamCityThreadPoolExecutor

public TeamCityThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  @NotNull
                                  TimeUnit unit,
                                  @NotNull
                                  BlockingQueue<Runnable> workQueue,
                                  @NotNull
                                  ThreadFactory threadFactory)

Method Detail

setPoolSize

public void setPoolSize(int poolSize)

Changes the maximum and core pool sizes of the thread pool. If the current maximum pool size and a core pool size are the same, then new pool size is set to the both maximum and core pool size. If the new pool size is smaller than the core pool size, then the core pool size is reduced to the new pool size value.

Parameters:

poolSize - the new maximum pool size

Since:

2022.1

beforeExecute

protected void beforeExecute(@NotNull
                             Thread thread,
                             @NotNull
                             Runnable runnable)

Overrides:

beforeExecute in class ThreadPoolExecutor

pause

public void pause()

resume

public void resume()

isPaused

public boolean isPaused()

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

Overrides:

shutdown in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable runnable,
                            Throwable throwable)

Overrides:

afterExecute in class ThreadPoolExecutor

getName

@NotNull
public static String getName(@NotNull
                             Object task)

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(@NotNull
                                           Runnable runnable,
                                           T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(@NotNull
                                           Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService

getQueuedTasksCount

public int getQueuedTasksCount()

Specified by:

getQueuedTasksCount in interface ExecutorServiceEx

Returns:

count of tasks in queue (not filtered - some can be cancelled)