Uses of Class
de.aristaflow.adept2.util.threading.Adept2ThreadFactory
-
Packages that use Adept2ThreadFactory Package Description de.aristaflow.adept2.util.threading de.aristaflow.adept2.util.threading.executor -
-
Uses of Adept2ThreadFactory in de.aristaflow.adept2.util.threading
Methods in de.aristaflow.adept2.util.threading with parameters of type Adept2ThreadFactory Modifier and Type Method Description static ExecutorService
ExecutorTools. createCachedExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory factory)
Creates a newCachedThreadPoolExecutor
with the given initial parameters and default rejected execution handler.static ExecutorService
ExecutorTools. 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 aAdept2ThreadFactory
for creating threads.static ExecutorService
ExecutorTools. createExecutor(int poolSize, Adept2ThreadFactory factory, boolean timeout, int queueLimit)
Creates a new executor service with the designated core pool size using the designated name and logger to create aAdept2ThreadFactory
for creating threads.static LoggingScheduledThreadPoolExecutor
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 Adept2ThreadFactory Constructor Description AbstractPipeliningExecutor(int limit, Adept2ThreadFactory threadFactory)
Deprecated.Creates a new thread pool executor with the designated number of pipelines and threads for different objects using the designate thread factory for creating threads.AbstractPipeliningExecutor(Adept2ThreadFactory threadFactory)
Deprecated.Creates a new thread pool executor with an unlimited amount of pipelines for different objects using the designate thread factory for creating threads.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, int queueLimit)
Creates a newAFThreadPoolExecutor
with the given initial parameters and default rejected execution handler.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, int queueLimit, Level minLogLevelPoolStatistics)
Creates a newAFThreadPoolExecutor
with 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 queueLimit)
Creates a newThreadPoolExecutor
with the given initial parameters.AFThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, Adept2ThreadFactory threadFactory, RejectedExecutionHandler handler, int queueLimit, Level minLogLevelPoolStatistics)
Creates a newThreadPoolExecutor
with the given initial parameters.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory)
Creates a newCachedThreadPoolExecutor
with the given initial parameters and default rejected execution handler.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimit, Level minLogLevelPoolStatistics)
Creates a newCachedThreadPoolExecutor
with the designated initial parameters and default rejected execution handler.CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics)
Creates a newCachedThreadPoolExecutor
with the designated initial parameters and default rejected execution handler.LimitedPipelineExecutor(int limit, Adept2ThreadFactory threadFactory)
Deprecated.Creates a new thread pool executor with the designated amount of pipelines and threads.LoggingScheduledThreadPoolExecutor(int corePoolSize, Adept2ThreadFactory threadFactory, boolean continueRegularAfterException)
Creates a newLoggingScheduledThreadPoolExecutor
with the designated core pool size and thread factory also providing the logger.LoggingScheduledThreadPoolExecutor(int corePoolSize, Adept2ThreadFactory threadFactory, RejectedExecutionHandler handler, boolean continueRegularAfterException)
Creates a newLoggingScheduledThreadPoolExecutor
with the designated core pool size, rejected execution handler and thread factory also providing the logger.UnlimitedPipelineExecutor(Adept2ThreadFactory threadFactory)
Deprecated.Creates a new thread pool executor with one pipeline per registered object and no limit for the threads. -
Uses of Adept2ThreadFactory in de.aristaflow.adept2.util.threading.executor
Constructors in de.aristaflow.adept2.util.threading.executor with parameters of type Adept2ThreadFactory Constructor Description AbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, 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.AbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimit, Level minLogLevelPoolStatistics)
Creates a new thread pool executor with the designated (maximum) amount of (core) threads, accepting exactly one piece of work per object.AbstractObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, 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.AbstractObjectOneWorkExecutor(boolean blockUntilFlush, Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with an unlimited amount of threads and objects, accepting exactly one piece of work per object.AbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, 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.AbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimit, Level minLogLevelPoolStatistics)
Creates a new thread pool executor with the designated (maximum) amount of (core) threads using the designated comparator for prioritising work.AbstractObjectSpecificExecutor(int corePoolSize, int maxPoolSize, boolean prestart, 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.AbstractObjectSpecificExecutor(int limit, 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.AbstractObjectSpecificExecutor(Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with an unlimited amount of threads for different objects using the designate thread factory for creating threads.AbstractPipeliningExecutor(int limit, Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with the designated number of pipelines and threads for different objects using the designate thread factory for creating threads.AbstractPipeliningExecutor(Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with an unlimited amount of pipelines for different objects using the designated thread factory for creating threads.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)
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, Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with an unlimited amount of threads and objects, accepting exactly one piece of work per object.ScheduledObjectOneWorkExecutor(boolean blockUntilFlush, int corePoolSize, int maxPoolSize, boolean prestart, 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, boolean prestart, int scheduledPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimit, 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, boolean prestart, 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, Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with an unlimited amount of threads and objects, accepting exactly one piece of work per object.UnlimitedPipelineExecutor(Adept2ThreadFactory threadFactory)
Creates a new thread pool executor with one pipeline per registered object and no limit for the threads.
-