public static interface Schedulers.Factory
|Modifier and Type||Method and Description|
default Scheduler newBoundedElastic(int threadCap, int queuedTaskCap, ThreadFactory threadFactory, int ttlSeconds)
Schedulerthat dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down. The underlying (user or daemon) threads can be evicted if idle for more than
The maximum number of created thread pools is bounded by the provided
threadCap- maximum number of underlying threads to create
queuedTaskCap- maximum number of tasks to enqueue when no more threads can be created. Can be
Integer.MAX_VALUEfor unbounded enqueueing.
ThreadFactoryto use each thread initialization
ttlSeconds- Time-to-live for an idle
Schedulerthat dynamically creates workers with an upper bound to the number of backing threads, reuses threads and evict idle ones
default Scheduler newParallel(int parallelism, ThreadFactory threadFactory)
Schedulerthat hosts a fixed pool of workers and is suited for parallel work.
parallelism- Number of pooled workers.
ThreadFactoryto use for the fixed initialized number of
Schedulerthat hosts a fixed pool of workers and is suited for parallel work
default Scheduler newSingle(ThreadFactory threadFactory)
Schedulerthat hosts a single worker and is suited for non-blocking work.
ThreadFactoryto use for the unique resource of the
Schedulerthat hosts a single worker