Package org.apache.accumulo.core.util
Class SimpleThreadPool
- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- java.util.concurrent.ThreadPoolExecutor
-
- org.apache.accumulo.core.util.SimpleThreadPool
-
- All Implemented Interfaces:
Executor
,ExecutorService
public class SimpleThreadPool extends ThreadPoolExecutor
Create a simple thread pool using common parameters.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SimpleThreadPool.CloseableSimpleThreadPool
-
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
-
-
Constructor Summary
Constructors Constructor Description SimpleThreadPool(int max, String name)
SimpleThreadPool(int max, String name, BlockingQueue<Runnable> queue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SimpleThreadPool.CloseableSimpleThreadPool
asCloseable()
Wrap this with a trivial object whoseAutoCloseable.close()
method callsThreadPoolExecutor.shutdownNow()
.-
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString
-
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
-
-
-
-
Constructor Detail
-
SimpleThreadPool
public SimpleThreadPool(int max, String name)
-
SimpleThreadPool
public SimpleThreadPool(int max, String name, BlockingQueue<Runnable> queue)
-
-
Method Detail
-
asCloseable
public SimpleThreadPool.CloseableSimpleThreadPool asCloseable()
Wrap this with a trivial object whoseAutoCloseable.close()
method callsThreadPoolExecutor.shutdownNow()
.
-
-