Uses of Class
de.aristaflow.adept2.util.threading.Adept2ThreadFactory
Packages that use Adept2ThreadFactory
Package
Description
-
Uses of Adept2ThreadFactory in de.aristaflow.adept2.util.threading
Methods in de.aristaflow.adept2.util.threading with parameters of type Adept2ThreadFactoryModifier and TypeMethodDescriptionstatic ExecutorServiceExecutorTools.createCachedExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory factory) Deprecated, for removal: This API element is subject to removal in a future version.static ExecutorServiceExecutorTools.createCachedExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory factory) Creates a newCachedThreadPoolExecutorwith the given initial parameters and default rejected execution handler.static ExecutorServiceExecutorTools.createExecutor(int poolSize, Adept2ThreadFactory factory, boolean timeout) Creates a new executor service with the designated core pool size using the designated name and logger to create aAdept2ThreadFactoryfor creating threads.static ExecutorServiceExecutorTools.createExecutor(int poolSize, Adept2ThreadFactory factory, boolean timeout, int queueLimitPoolStatistics) Creates a new executor service with the designated core pool size using the designated name and logger to create aAdept2ThreadFactoryfor creating threads.static ExecutorServiceExecutorTools.createExecutor(int poolSize, Adept2ThreadFactory factory, boolean timeout, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new executor service with the designated core pool size using the designated name and logger to create aAdept2ThreadFactoryfor creating threads.ExecutorTools.createScheduledExecutor(int poolSize, Adept2ThreadFactory factory, boolean continueRegularAfterException) Creates a new scheduled executor service with the designated minimal pool size using the designated factory for creating threads.Constructors in de.aristaflow.adept2.util.threading with parameters of type Adept2ThreadFactoryModifierConstructorDescriptionAFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics) Creates a newAFThreadPoolExecutorwith the given initial parameters and default rejected execution handler.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a newAFThreadPoolExecutorwith the given initial parameters and default rejected execution handler.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, RejectedExecutionHandler handler, int queueLimitPoolStatistics) Creates a newThreadPoolExecutorwith the given initial parameters.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, RejectedExecutionHandler handler, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a newThreadPoolExecutorwith the given initial parameters.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a newCachedThreadPoolExecutorwith the given initial parameters and default rejected execution handler.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a newCachedThreadPoolExecutorwith the designated initial parameters and default rejected execution handler.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a newCachedThreadPoolExecutorwith the designated initial parameters and default rejected execution handler.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Creates a newCachedThreadPoolExecutorwith the designated initial parameters and default rejected execution handler.LoggingScheduledThreadPoolExecutor(int corePoolSize, Adept2ThreadFactory threadFactory, boolean continueRegularAfterException) Creates a newLoggingScheduledThreadPoolExecutorwith the designated core pool size and thread factory also providing the logger.LoggingScheduledThreadPoolExecutor(int corePoolSize, Adept2ThreadFactory threadFactory, RejectedExecutionHandler handler, boolean continueRegularAfterException) Creates a newLoggingScheduledThreadPoolExecutorwith the designated core pool size, rejected execution handler and thread factory also providing the logger. -
Uses of Adept2ThreadFactory in de.aristaflow.adept2.util.threading.executor
Constructors in de.aristaflow.adept2.util.threading.executor with parameters of type Adept2ThreadFactoryModifierConstructorDescriptionprotectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated (maximum) amount of (core) threads (and unlimited objects), accepting exactly one piece of work per object.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads (and unlimited objects), accepting exactly one piece of work per object.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads, accepting exactly one piece of work per object.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads, accepting exactly one piece of work per object.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with an unlimited amount objects and the designated maximum amount of threads, accepting exactly one piece of work per object.protectedAbstractObjectOneWorkExecutor(boolean blockUntilFlush, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated number of threads and threads for different objects using the designate thread factory for creating threads.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated number of threads and threads for different objects using the designate thread factory for creating threads.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads using the designated comparator for prioritising work.protectedAbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads using the designated comparator for prioritising work.protectedAbstractObjectSpecificExecutor(int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated maximum amount of threads and threads for different objects.protectedAbstractObjectSpecificExecutor(Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.protectedAbstractPipeliningExecutor(int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated maximum amount of threads for different objects using the designate thread factory for creating threads.protectedAbstractPipeliningExecutor(Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.UseAbstractPipeliningExecutor(int, Adept2ThreadFactory)instead.LimitedPipelineExecutor(int limit, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated amount of pipelines and threads.ObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.ObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.ObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated (maximum) amount of (core) threads (and unlimited objects), accepting exactly one piece of work per object.ObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads (and unlimited objects), accepting exactly one piece of work per object.ObjectOneWorkExecutor(boolean blockUntilFlush, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with an unlimited amount objects and the designated maximum amount of threads, accepting exactly one piece of work per object.ObjectOneWorkExecutor(boolean blockUntilFlush, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, int scheduledPoolSize, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, int scheduledPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, int scheduledPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Deprecated, for removal: This API element is subject to removal in a future version.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, int scheduledPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with the designated (maximum) amount of (core) threads (and unlimited objects), accepting exactly one piece of work per object.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, int scheduledPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads, accepting exactly one piece of work per object.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, int scheduledPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics) Creates a new thread pool executor with the designated (maximum) amount of (core) threads, accepting exactly one piece of work per object.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with an unlimited amount of objects and the designated maximum amount of threads, accepting exactly one piece of work per object.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.UnlimitedPipelineExecutor(int maxPoolSize, Adept2ThreadFactory threadFactory) Creates a new thread pool executor with one pipeline per registered object and the designated maximum amount of threads.UnlimitedPipelineExecutor(Adept2ThreadFactory threadFactory) Deprecated, for removal: This API element is subject to removal in a future version.UseUnlimitedPipelineExecutor(int, Adept2ThreadFactory)instead.
ExecutorTools.createCachedExecutor(int, int, Adept2ThreadFactory)instead.