multithreading Executors
Syntax
-
ThreadPoolExecutor
-
ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) -
ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) -
ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) -
ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) -
Executors.callable(PrivilegedAction<?> action) -
Executors.callable(PrivilegedExceptionAction<?> action) -
Executors.callable(Runnable task) -
Executors.callable(Runnable task, T result) -
Executors.defaultThreadFactory() -
Executors.newCachedThreadPool() -
Executors.newCachedThreadPool(ThreadFactory threadFactory) -
Executors.newFixedThreadPool(int nThreads) -
Executors.newFixedThreadPool(int nThreads, ThreadFactory threadFactory) -
Executors.newScheduledThreadPool(int corePoolSize) -
Executors.newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory) -
Executors.newSingleThreadExecutor() -
Executors.newSingleThreadExecutor(ThreadFactory threadFactory)
Parameters
| Parameter | Detail |
|---|---|
| corePoolSize | Minimum number of threads to keep in the pool. |
| maximumPoolSize | Maximum number of threads to allow in the pool. |
| keepAliveTime | When number of threads is greater than the core, the noncore threads (excess idle threads) will wait for time defined by this parameter for new tasks before terminating. |
| unit | Time unit for keepAliveTime. |
| timeout | the maximum time to wait |
| workQueue | The type of queue that our Executor is going to use |
| threadFactory | The factory to use when creating new threads |
| nThreads | The number of threads in the pool |
| executor | The underlying implementation |
| task | the task to run |
| result | The result to return |
| action | The privileged action to run |
| callable | The underlying task |
Remarks
The different types of Threadpools and Queues that are explained below, have been taken from the information and knowledge from [oracle documentation][1] and [Jakob Jenkov][2] blog where you can learn a lot about concurrency in java.
Different types of ThreadPools
SingleThreadExecutor: Executor that uses a single worker thread operating off an unbounded queue, and uses the provided ThreadFactory to create a new thread when needed. Unlike the otherwise equivalent newFixedThreadPool(1, threadFactory) the returned executor is guaranteed not to be reconfigurable to use additional threads.
FixedThreadPool: thread pool that reuses a fixed number of threads operating off a shared unbounded queue, using the provided ThreadFactory to create new threads when needed. At any point, at most nThreads threads will be active processing tasks. If additional tasks are submitted when all threads are active, they will wait in the queue until a thread is available. If any thread terminates due to a failure during execution prior to shutdown, a new one will take its place if needed to execute subsequent tasks. The threads in the pool will exist until it is explicitly shutdown.
CachedThreadPool: Thread pool that creates new threads as needed, but will reuse previously constructed threads when they are available, and uses the provided ThreadFactory to create new threads when needed.
SingleThreadScheduledExecutor: Single-threaded executor that can schedule commands to run after a given delay, or to execute periodically. (Note however that if this single thread terminates due to a failure during execution prior to shutdown, a new one will take its place if needed to execute subsequent tasks.) Tasks are guaranteed to execute sequentially, and no more than one task will be active at any given time. Unlike the otherwise equivalent newScheduledThreadPool(1, threadFactory) the returned executor is guaranteed not to be reconfigurable to use additional threads.
ScheduledThreadPool: Thread pool that can schedule commands to run after a given delay, or to execute periodically. Different types of Work Queues
