Thread Pools with ExecutorService, Callable<T>, and Future<T>0%

JDBC Architecture, Drivers, and DriverManager Connection

Thread Pools with ExecutorService, Callable<T>, and Future<T>

Advanced16 min read•Updated: 2025-01-15

🏭 Thread Pools with ExecutorService, Callable<T>, and Future<T>

Introduction

Creating a new OS thread has high overhead: memory allocation for the thread stack (~1MB per thread), context-switching costs, and CPU thrashing. In production systems, spawning new Thread() for every request will quickly lead to OutOfMemoryError.

The Executor Framework decouples task submission from thread execution through managed Thread Pools.

📦 Factory Methods in `Executors`

1// 1. Fixed Thread Pool: Constant number of worker threads
2ExecutorService fixedPool = Executors.newFixedThreadPool(8);
3 
4// 2. Cached Thread Pool: Spawns threads as needed, reuses idle ones
5ExecutorService cachedPool = Executors.newCachedThreadPool();
6 
7// 3. Single Thread Executor: Sequential FIFO task queue
8ExecutorService singlePool = Executors.newSingleThreadExecutor();

⚡ `Runnable` vs `Callable<V>`

Runnable: void run() - cannot return a value, cannot throw checked exceptions.
Callable<V>: V call() throws Exception - returns a computed result and can propagate checked exceptions!

1import java.util.concurrent.*;
2 
3public class ExecutorDemo {
4    public static void main(String[] args) throws Exception {
5        ExecutorService executor = Executors.newFixedThreadPool(4);
6 
7        // Submit Callable task
8        Callable<Double> calculateTaxTask = () -> {
9            Thread.sleep(1000); // Simulate network or calculation delay
10            return 14500.50 * 0.18;
11        };
12 
13        // Future acts as a placeholder for the asynchronous result
14        Future<Double> futureResult = executor.submit(calculateTaxTask);
15 
16        System.out.println("Task submitted. Main thread continues doing work...");
17 
18        // Blocks until worker finishes and returns value
19        Double tax = futureResult.get(3, TimeUnit.SECONDS);
20        System.out.printf("Calculated Tax: ₹%.2f%n", tax);
21 
22        // Graceful shutdown protocol
23        executor.shutdown();
24        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
25            executor.shutdownNow();
26        }
27    }
28}

🛑 The Standard Graceful Shutdown Recipe

1executor.shutdown(); // Refuses new tasks, lets running ones finish
2try {
3    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
4        executor.shutdownNow(); // Cancel running tasks
5    }
6} catch (InterruptedException e) {
7    executor.shutdownNow();
8}

Next Lesson

JDBC Architecture, Drivers, and DriverManager Connection

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
java.util.concurrent: ReentrantLock, ReadWriteLock, and Condition	JDBC Architecture, Drivers, and DriverManager Connection

Practice Quiz

Test your understanding of this lesson with 1 questions. Each question has one correct answer.

Previous Next

PreviousPrevNext

MSK Institute • Shikohabad

Loading Page Content...

Preparing courses, live labs, and learning resources.सामग्री लोड हो रही है, कृपया प्रतीक्षा करें...

Connecting serverPlease wait...

💻 Practical Labs🚀 Free Demo📜 Verified Certificates

JDBC Architecture, Drivers, and DriverManager Connection

Thread Pools with ExecutorService, Callable<T>, and Future<T>

Advanced16 min read•Updated: 2025-01-15

Study Materials

🏭 Thread Pools with ExecutorService, Callable<T>, and Future<T>

Introduction

The Executor Framework decouples task submission from thread execution through managed Thread Pools.

📦 Factory Methods in `Executors`

1// 1. Fixed Thread Pool: Constant number of worker threads
2ExecutorService fixedPool = Executors.newFixedThreadPool(8);
3 
4// 2. Cached Thread Pool: Spawns threads as needed, reuses idle ones
5ExecutorService cachedPool = Executors.newCachedThreadPool();
6 
7// 3. Single Thread Executor: Sequential FIFO task queue
8ExecutorService singlePool = Executors.newSingleThreadExecutor();

⚡ `Runnable` vs `Callable<V>`

Runnable: void run() - cannot return a value, cannot throw checked exceptions.
Callable<V>: V call() throws Exception - returns a computed result and can propagate checked exceptions!

1import java.util.concurrent.*;
2 
3public class ExecutorDemo {
4    public static void main(String[] args) throws Exception {
5        ExecutorService executor = Executors.newFixedThreadPool(4);
6 
7        // Submit Callable task
8        Callable<Double> calculateTaxTask = () -> {
9            Thread.sleep(1000); // Simulate network or calculation delay
10            return 14500.50 * 0.18;
11        };
12 
13        // Future acts as a placeholder for the asynchronous result
14        Future<Double> futureResult = executor.submit(calculateTaxTask);
15 
16        System.out.println("Task submitted. Main thread continues doing work...");
17 
18        // Blocks until worker finishes and returns value
19        Double tax = futureResult.get(3, TimeUnit.SECONDS);
20        System.out.printf("Calculated Tax: ₹%.2f%n", tax);
21 
22        // Graceful shutdown protocol
23        executor.shutdown();
24        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
25            executor.shutdownNow();
26        }
27    }
28}

🛑 The Standard Graceful Shutdown Recipe

1executor.shutdown(); // Refuses new tasks, lets running ones finish
2try {
3    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
4        executor.shutdownNow(); // Cancel running tasks
5    }
6} catch (InterruptedException e) {
7    executor.shutdownNow();
8}

Next Lesson

JDBC Architecture, Drivers, and DriverManager Connection

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
java.util.concurrent: ReentrantLock, ReadWriteLock, and Condition	JDBC Architecture, Drivers, and DriverManager Connection

Practice Quiz

Test your understanding of this lesson with 1 questions. Each question has one correct answer.

Previous Next

🏭 Thread Pools with ExecutorService, Callable<T>, and Future<T>

Introduction

📦 Factory Methods in Executors

⚡ Runnable vs Callable<V>

🛑 The Standard Graceful Shutdown Recipe

JDBC Architecture, Drivers, and DriverManager Connection

Related Lessons

Practice Quiz

Loading Page Content...

🏭 Thread Pools with ExecutorService, Callable<T>, and Future<T>

Introduction

📦 Factory Methods in Executors

⚡ Runnable vs Callable<V>

🛑 The Standard Graceful Shutdown Recipe

JDBC Architecture, Drivers, and DriverManager Connection

Related Lessons

Practice Quiz

📦 Factory Methods in `Executors`

⚡ `Runnable` vs `Callable<V>`

📦 Factory Methods in `Executors`

⚡ `Runnable` vs `Callable<V>`