Class DaemonPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.ojalgo.concurrent.DaemonPoolExecutor

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public final class DaemonPoolExecutor
extends ThreadPoolExecutor

Nested Class Summary

Nested classes/interfaces inherited from class ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicInteger	COUNTER
private static final ThreadGroup	GROUP
(package private) static final DaemonPoolExecutor	INSTANCE

Constructor Summary

Constructors

Constructor	Description
DaemonPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
DaemonPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
DaemonPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
DaemonPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method	Description
static Future<?>	invoke(Runnable task)
static <T> Future<T>	invoke(Runnable task, T result)
static <T> Future<T>	invoke(Callable<T> task)
static ExecutorService	newCachedThreadPool(String name)	Like Executors.newCachedThreadPool() but with identifiable (daemon) threads
static ExecutorService	newFixedThreadPool(String name, int nThreads)	Like Executors.newFixedThreadPool(int) but with identifiable (daemon) threads
(package private) static ThreadFactory	newProcessAwareThreadFactory(String name)	Create a ThreadFactory producing ProcessAwareThreads.
static ScheduledExecutorService	newScheduledThreadPool(String name, int corePoolSize)	Like Executors.newScheduledThreadPool(int) but with identifiable (daemon) threads
static ExecutorService	newSingleThreadExecutor(String name)	Like Executors.newSingleThreadExecutor() but with identifiable (daemon) threads
static ScheduledExecutorService	newSingleThreadScheduledExecutor(String name)	Like Executors.newSingleThreadScheduledExecutor() but with identifiable (daemon) threads
static ThreadFactory	newThreadFactory(String name)
static ThreadFactory	newThreadFactory(ThreadGroup group, String name)

Methods inherited from class 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 AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ExecutorService

close

Field Details

COUNTER

private static final AtomicInteger COUNTER

GROUP

private static final ThreadGroup GROUP

INSTANCE

static final DaemonPoolExecutor INSTANCE

Constructor Details

DaemonPoolExecutor

DaemonPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue)

DaemonPoolExecutor

DaemonPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 RejectedExecutionHandler handler)

DaemonPoolExecutor

DaemonPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory)

DaemonPoolExecutor

DaemonPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory,
 RejectedExecutionHandler handler)

Method Details

invoke

public static <T> Future<T> invoke(Callable<T> task)

See Also:

• AbstractExecutorService.submit(java.util.concurrent.Callable)

invoke

public static Future<?> invoke(Runnable task)

See Also:

• AbstractExecutorService.submit(java.lang.Runnable)

invoke

public static <T> Future<T> invoke(Runnable task,
 T result)

See Also:

• AbstractExecutorService.submit(java.lang.Runnable, java.lang.Object)

newCachedThreadPool

public static ExecutorService newCachedThreadPool(String name)

Like Executors.newCachedThreadPool() but with identifiable (daemon) threads

newFixedThreadPool

public static ExecutorService newFixedThreadPool(String name,
 int nThreads)

Like Executors.newFixedThreadPool(int) but with identifiable (daemon) threads

newScheduledThreadPool

public static ScheduledExecutorService newScheduledThreadPool(String name,
 int corePoolSize)

Like Executors.newScheduledThreadPool(int) but with identifiable (daemon) threads

newSingleThreadExecutor

public static ExecutorService newSingleThreadExecutor(String name)

Like Executors.newSingleThreadExecutor() but with identifiable (daemon) threads

newSingleThreadScheduledExecutor

public static ScheduledExecutorService newSingleThreadScheduledExecutor(String name)

Like Executors.newSingleThreadScheduledExecutor() but with identifiable (daemon) threads

newThreadFactory

public static ThreadFactory newThreadFactory(String name)

newThreadFactory

public static ThreadFactory newThreadFactory(ThreadGroup group,
 String name)

newProcessAwareThreadFactory

static ThreadFactory newProcessAwareThreadFactory(String name)

Create a ThreadFactory producing ProcessAwareThreads. These threads are daemon threads and can be used to "own" an external process: if the thread is interrupted, the process is forcibly destroyed.