Understanding Java ThreadPoolExecutor: Creation, Execution Flow, and Core Parameters

As CPU core counts increase, multithreading becomes essential for server‑side development. Thread creation and destruction are costly, so thread pools are used to reuse threads efficiently.

1. Thread Pool Creation

The most complete ThreadPoolExecutor constructor includes the following parameters:

corePoolSize: Number of core threads that stay alive even when idle.

maximumPoolSize: Maximum number of threads that can be created.

keepAliveTime: Time that excess idle threads wait before terminating.

unit: Time unit for keepAliveTime (e.g., TimeUnit.SECONDS).

workQueue: Blocking queue that holds submitted tasks.

threadFactory: Factory that creates new threads, usually to set names.

handler: Rejection policy invoked when the pool is saturated.

2. Thread Pool Execution Flow

When a task is submitted, the pool first checks whether the current thread count is less than corePoolSize. If it is, a new thread is created; otherwise the task is placed into workQueue. If the queue is full, the pool checks against maximumPoolSize, creating a non‑core thread if possible, or invoking the rejection handler when the pool cannot accept more tasks.

2.1 executor method

This method illustrates the decision steps: create a worker if below corePoolSize, otherwise enqueue, otherwise create a non‑core thread, otherwise reject.

2.2 addWorker method

The addWorker method shows how a Worker object and its underlying Thread are instantiated and started.

The lower part of the method creates the Worker and starts the thread.

2.3 Worker implementation

The Worker uses the threadFactory to create a thread; its run method triggers task execution.

2.4 runWorker logic

The runWorker method repeatedly calls getTask to fetch tasks from the queue and executes them until getTask returns null, at which point the thread exits.

2.5 getTask implementation

If allowCoreThreadTimeOut is false (default), threads with a count greater than corePoolSize poll the workQueue with a timeout equal to keepAliveTime. If the poll returns null, the thread terminates. Threads at or below corePoolSize block on take() awaiting tasks.