Package org.languagetool.tools

Class LtThreadPoolFactory

java.lang.Object

org.languagetool.tools.LtThreadPoolFactory

public final class LtThreadPoolFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	LtThreadPoolFactory.LtRejectedExecutionHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final ThreadPoolExecutor	defaultPool
private static final ConcurrentMap<String,ThreadPoolExecutor>	executorServices
private static final LtThreadPoolFactory.LtRejectedExecutionHandler	handler
private static final io.prometheus.client.Counter	rejectedTasks
static final String	REMOTE_RULE_EXECUTING_POOL
static final int	REMOTE_RULE_POOL_SIZE_FACTOR
static final String	SERVER_POOL
static final String	TEXT_CHECKER_POOL
private static final io.prometheus.client.Gauge	threadGauge

Constructor Summary

Constructors

Modifier	Constructor	Description
private	LtThreadPoolFactory()

Method Summary

Modifier and Type	Method	Description
static ThreadPoolExecutor	createFixedThreadPoolExecutor(String identifier, int maxThreads, int maxTaskInQueue, boolean isDaemon, Thread.UncaughtExceptionHandler exceptionHandler, boolean reuse)
static ThreadPoolExecutor	createFixedThreadPoolExecutor(String identifier, int corePool, int maxThreads, int maxTaskInQueue, long keepAliveTimeSeconds, boolean isDaemon, Thread.UncaughtExceptionHandler exceptionHandler, boolean reuse)
static Optional<ThreadPoolExecutor>	getFixedThreadPoolExecutor(String identifier)
private static ThreadPoolExecutor	getNewThreadPoolExecutor(String identifier, int corePool, int maxThreads, int maxTaskInQueue, long keepAliveTimeSeconds, boolean isDaemon, Thread.UncaughtExceptionHandler exceptionHandler)

Methods inherited from class java.lang.Object

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

Field Details

SERVER_POOL

public static final String SERVER_POOL

See Also:

• Constant Field Values

TEXT_CHECKER_POOL

public static final String TEXT_CHECKER_POOL

See Also:

• Constant Field Values

REMOTE_RULE_EXECUTING_POOL

public static final String REMOTE_RULE_EXECUTING_POOL

See Also:

• Constant Field Values

REMOTE_RULE_POOL_SIZE_FACTOR

public static final int REMOTE_RULE_POOL_SIZE_FACTOR

See Also:

• Constant Field Values

executorServices

private static final ConcurrentMap<String,ThreadPoolExecutor> executorServices

rejectedTasks

private static final io.prometheus.client.Counter rejectedTasks

threadGauge

private static final io.prometheus.client.Gauge threadGauge

handler

private static final LtThreadPoolFactory.LtRejectedExecutionHandler handler

defaultPool

static final ThreadPoolExecutor defaultPool

Constructor Details

LtThreadPoolFactory

private LtThreadPoolFactory()

Method Details

createFixedThreadPoolExecutor

public static ThreadPoolExecutor createFixedThreadPoolExecutor(@NotNull
 String identifier,
 int maxThreads,
 int maxTaskInQueue,
 boolean isDaemon,
 @NotNull
 Thread.UncaughtExceptionHandler exceptionHandler,
 boolean reuse)

Parameters:

identifier - Name of the thread-pool, will be used as name of the threads in the threadPool

maxThreads - Number of parallel threads running in this pool

maxTaskInQueue - Number of maximum Task in the pool queue

isDaemon - Run the threads as daemon threads

exceptionHandler - Handler for exceptions in Thread

reuse - True if thread-pool should be reused

Returns:

a Fixed ThreadPoolExecutor

createFixedThreadPoolExecutor

public static ThreadPoolExecutor createFixedThreadPoolExecutor(@NotNull
 String identifier,
 int corePool,
 int maxThreads,
 int maxTaskInQueue,
 long keepAliveTimeSeconds,
 boolean isDaemon,
 @NotNull
 Thread.UncaughtExceptionHandler exceptionHandler,
 boolean reuse)

Parameters:

identifier - Name of the thread-pool, will be used as name of the threads in the threadPool

corePool - Number of core pool threads

maxThreads - Maximum number of parallel threads running in this pool

maxTaskInQueue - Number of maximum Task in the pool queue

keepAliveTimeSeconds - keep-alive time for idle threads

isDaemon - Run the threads as daemon threads

exceptionHandler - Handler for exceptions in Thread

reuse - True if thread-pool should be reused

Returns:

a Fixed ThreadPoolExecutor

getNewThreadPoolExecutor

@NotNull
private static ThreadPoolExecutor getNewThreadPoolExecutor(@NotNull
 String identifier,
 int corePool,
 int maxThreads,
 int maxTaskInQueue,
 long keepAliveTimeSeconds,
 boolean isDaemon,
 @NotNull
 Thread.UncaughtExceptionHandler exceptionHandler)

getFixedThreadPoolExecutor

public static Optional<ThreadPoolExecutor> getFixedThreadPoolExecutor(@NotNull
 String identifier)

Parameters:

identifier - Name of an already created tread-pool

Returns:

An optional of ThreadPoolExecutor (Null or Object)