Class DynamicSizedSchedulerImpl
java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
java.util.concurrent.ScheduledThreadPoolExecutor
org.mariadb.jdbc.internal.util.scheduler.DynamicSizedSchedulerImpl
- All Implemented Interfaces:
Executor
,ExecutorService
,ScheduledExecutorService
,DynamicSizedSchedulerInterface
public class DynamicSizedSchedulerImpl
extends ScheduledThreadPoolExecutor
implements DynamicSizedSchedulerInterface
-
Nested Class Summary
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
-
Constructor Summary
ConstructorsConstructorDescriptionDynamicSizedSchedulerImpl
(int corePoolSize, String poolName, int maximumPoolSize) Initialize a scheduler with dynamic pool size. -
Method Summary
Modifier and TypeMethodDescriptionvoid
setPoolSize
(int newSize) Update the pool thread count with this new value.Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor
decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
Methods inherited from interface java.util.concurrent.ScheduledExecutorService
schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay
-
Constructor Details
-
DynamicSizedSchedulerImpl
Initialize a scheduler with dynamic pool size.- Parameters:
corePoolSize
- initial Core pool sizepoolName
- name of pool to identify threadsmaximumPoolSize
- maximum pool size
-
-
Method Details
-
setPoolSize
public void setPoolSize(int newSize) Description copied from interface:DynamicSizedSchedulerInterface
Update the pool thread count with this new value.- Specified by:
setPoolSize
in interfaceDynamicSizedSchedulerInterface
- Parameters:
newSize
- New pool size that is superior to 0
-