Package org.infinispan.factories.threads
Class NonBlockingThreadPoolExecutorFactory
- java.lang.Object
-
- org.infinispan.factories.threads.AbstractThreadPoolExecutorFactory<ExecutorService>
-
- org.infinispan.factories.threads.NonBlockingThreadPoolExecutorFactory
-
- All Implemented Interfaces:
ThreadPoolExecutorFactory<ExecutorService>
public class NonBlockingThreadPoolExecutorFactory extends AbstractThreadPoolExecutorFactory<ExecutorService>
Executor Factory used for non blocking executors which utilizesThreadPoolExecutor
internally.- Author:
- wburns
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_KEEP_ALIVE_MILLIS
-
Fields inherited from class org.infinispan.factories.threads.AbstractThreadPoolExecutorFactory
coreThreads, keepAlive, maxThreads, queueLength
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
NonBlockingThreadPoolExecutorFactory(int maxThreads, int coreThreads, int queueLength, long keepAlive)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static NonBlockingThreadPoolExecutorFactory
create(int maxThreads, int queueSize)
ExecutorService
createExecutor(ThreadFactory threadFactory)
boolean
createsNonBlockingThreads()
String
toString()
void
validate()
Validate parameters for the thread pool executor factory-
Methods inherited from class org.infinispan.factories.threads.AbstractThreadPoolExecutorFactory
coreThreads, keepAlive, maxThreads, queueLength
-
-
-
-
Field Detail
-
DEFAULT_KEEP_ALIVE_MILLIS
public static final int DEFAULT_KEEP_ALIVE_MILLIS
- See Also:
- Constant Field Values
-
-
Method Detail
-
createsNonBlockingThreads
public boolean createsNonBlockingThreads()
-
createExecutor
public ExecutorService createExecutor(ThreadFactory threadFactory)
-
validate
public void validate()
Description copied from interface:ThreadPoolExecutorFactory
Validate parameters for the thread pool executor factory
-
create
public static NonBlockingThreadPoolExecutorFactory create(int maxThreads, int queueSize)
-
-