Index (Bounded Executor 1.0.4 API)

A

ABORT - Enum constant in enum class dev.aahmedlab.concurrent.RejectionPolicy: Throws RejectedExecutionException.
awaitTermination(long, TimeUnit) - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

BLOCK - Enum constant in enum class dev.aahmedlab.concurrent.RejectionPolicy: Blocks the calling thread until space becomes available.
BoundedExecutor - Class in dev.aahmedlab.concurrent: A bounded executor implementation with a bounded queue and configurable rejection policies.
BoundedExecutor(int, int, RejectionPolicy) - Constructor for class dev.aahmedlab.concurrent.BoundedExecutor: Creates a bounded executor with the specified parameters.

CALLER_RUNS - Enum constant in enum class dev.aahmedlab.concurrent.RejectionPolicy: Runs the task in the calling thread.
create(int, int) - Static method in class dev.aahmedlab.concurrent.BoundedExecutor: Creates a bounded executor with a BLOCK rejection policy.
createCpuBound() - Static method in class dev.aahmedlab.concurrent.BoundedExecutor: Creates an executor optimized for CPU-bound tasks.
createFixed(int) - Static method in class dev.aahmedlab.concurrent.BoundedExecutor: Creates a fixed-size executor with a bounded queue.
createIoBound() - Static method in class dev.aahmedlab.concurrent.BoundedExecutor: Creates an executor optimized for I/O-bound tasks.

dev.aahmedlab.concurrent - package dev.aahmedlab.concurrent
DISCARD - Enum constant in enum class dev.aahmedlab.concurrent.RejectionPolicy: Silently discards the task.
DISCARD_OLDEST - Enum constant in enum class dev.aahmedlab.concurrent.RejectionPolicy: Discards the oldest task and adds the new one.

getPoolSize() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns the number of worker threads in this pool.
getQueueRemainingCapacity() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns the remaining capacity of the queue.
getQueueSize() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns the current number of tasks in the queue.

isQueueFull() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns true if the queue is full.
isRunning() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns true if this pool is running and accepting new tasks.
isShutdown() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns true if this pool has been shut down.
isTerminated() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Returns true if this pool has been terminated.

RejectionPolicy - Enum Class in dev.aahmedlab.concurrent: Policy for handling task submissions when the queue is full.

shutdown() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Initiates a graceful shutdown of the bounded executor.
shutdownNow() - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Initiates an immediate shutdown of the bounded executor.
submit(Runnable) - Method in class dev.aahmedlab.concurrent.BoundedExecutor: Submits a task for execution in the bounded executor.

valueOf(String) - Static method in enum class dev.aahmedlab.concurrent.RejectionPolicy: Returns the enum constant of this class with the specified name.
values() - Static method in enum class dev.aahmedlab.concurrent.RejectionPolicy: Returns an array containing the constants of this enum class, in the order they are declared.