Java newCachedThreadPool Example

In this tutorial, we will learn about Executor’s newCachedThreadPool factory method.
In the last tutorial, I have shared introduction to ThreadPoolExecutor. If you are not aware of concepts of ThreadPoolExecutor, you should go through that first.

Executor’s newCachedThreadPool factory method :

This method returns an unbounded thread pool. It sets maximum pool size to Integer.Max and it will create new threads depending on demand. If demand decreases, it will tear down threads if threads are idle for more than 1 min.

Example:

Let’s create a Task. Here Task will be to read different files and process them.

package org.arpit.java2blog.bean;

public class FetchDataFromFile implements Runnable{

private final String fileName;

public FetchDataFromFile(String fileName) {

super();

this.fileName = fileName;

}

@Override

public void run() {

try {

System.out.println("Fetching data from "+fileName+" by "+Thread.currentThread().getName());

Thread.sleep(5000); // Reading file

System.out.println("Read file successfully: "+fileName+" by "+Thread.currentThread().getName());

} catch (InterruptedException e) {

e.printStackTrace();

}

public String getFileName() {

return fileName;

}

Let’s create ThreadPoolExecutor which will consume above task and process it.

package org.arpit.java2blog;

import java.util.concurrent.Executors;

import java.util.concurrent.ThreadPoolExecutor;

public class ThreadPoolExecutorMain {

public static void main(String args[]) {

// Getting instance of ThreadPoolExecutor using Executors.newCachedThreadPool factory method

ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool();

for (int i = 1; i <= 10; i++) {

FetchDataFromFile fdff = new FetchDataFromFile("File :" + i);

System.out.println("A new file has been added to read : " + fdff.getFileName());

threadPoolExecutor.execute(fdff);

}

threadPoolExecutor.shutdown();

}

When you run above program, you will get below output:

A new file has been added to read : File :1

A new file has been added to read : File :2

Fetching data from File :1 by pool-1-thread-1

Fetching data from File :2 by pool-1-thread-2

A new file has been added to read : File :3

A new file has been added to read : File :4

Fetching data from File :3 by pool-1-thread-3

Fetching data from File :4 by pool-1-thread-4

A new file has been added to read : File :5

Fetching data from File :5 by pool-1-thread-5

A new file has been added to read : File :6

Fetching data from File :6 by pool-1-thread-6

A new file has been added to read : File :7

Fetching data from File :7 by pool-1-thread-7

A new file has been added to read : File :8

A new file has been added to read : File :9

Fetching data from File :8 by pool-1-thread-8

A new file has been added to read : File :10

Fetching data from File :9 by pool-1-thread-9

Fetching data from File :10 by pool-1-thread-10

If you notice, we have submitted 10 tasks and it has created 10 new threads depending on demand.If any thread remains idle for more than one minute, it will tear it down. newCachedThreadPool is a good choice when you want better queuing performance than newFixedThreadPool. If you want to restrict number of concurrent task for resource management, go with newFixedThreadPool.

Get Thread Id in Java

ArrayBlockingQueue in java

Java wait seconds or delay Java program for few secs

How to print even and odd numbers using threads in java

Why wait(), notify() And notifyAll() methods are in Object Class

Custom BlockingQueue implementation in java

Difference between Runnable and Callable in java

Print sequence using 3 threads in java

Java Runnable example

Java Executor framework tutorial with example

Author

Difference between Runnable and Callable in java

Concurrent APIs Multithreading Core Java interview Interview

16 December

Difference between Runnable and Callable in java

Runnable and Callable interface both are used in the multithreading environment.Callable is available in java.util.concurrent.Callable package and Runnable in java.lang.Thread. Difference between Runnable and Callable interface in java Runnable was introduced in java 1.0 version While Callable is an extended version of Runnable and introduced in java 1.5 to address the limitation of Runnable. Runnable […]

Concurrent APIs Core Java interview Multithreading

13 June

Java Executor framework tutorial with example

Table of ContentsExecutorExecutorServiceScheduledExecutorServiceExecutorsThreadPoolExecutor Java 5 has introduced new framework called Executor Framework for managing threads.We have already seen before how to create a thread. If you have noted, we need to create an object of thread class using new Thread(runnableObject), so we need to create thread object for each task.Imagine a situation where you have […]

Concurrent APIs Multithreading Core Java interview Interview

09 June

Java ExecutorCompletionService

Table of ContentsWhy you may need to use ExecutorCompletionService:Java ExecutorCompletionService example: In this post, we will see about Java ExecutorCompletionService example. ExecutorCompletionService class implements CompletionService. This class returns Future object in completion order. Why you may need to use ExecutorCompletionService: Let’s understand with the help of scenario: Let’s say you have 5 tasks, you submit it to the […]

Concurrent APIs Core Java interview Multithreading

05 June

Java newSingleThreadExecutor example

Table of ContentsSyntax:Java newSingleThreadExecutor example:Difference between newSingleThreadExecutor and newFixedThreadPool(1): In this tutorial, we will learn about Executor’s newSingleThreadExecutor factory method. In the last tutorial, I have shared an introduction to ThreadPoolExecutor. If you are not aware of concepts of ThreadPoolExecutor, you should go through that first. Executor’s newSingleThreadExecutor factory method : This method returns thread […]

Concurrent APIs Core Java interview Multithreading

29 May

Java ScheduledThreadPoolExecutor Example

Table of ContentsJava ScheduledThreadPoolExecutor Example:ScheduledThreadPoolExecutor’s scheduleAtFixedRate example:ScheduledThreadPoolExecutor’s scheduleWithFixedDelay example: There are multiple ways to schedule a task in java. We have already Java timer to schedule a task but the problem with timers task is that you can execute one task at a time.So if the current task takes longer subsequent job will be delayed. […]

Concurrent APIs Multithreading Core Java interview Interview

28 May

Java FutureTask example

Table of ContentsJava FutureTask example:Explanation: In this tutorial, we will see about Java FutureTask example. FutureTask class has been introduced in JDK 5 with Executor Framework. FutureTask class is the concrete implementation of the Future object and provides methods for start and cancel the task.It also provides method to see if the computation is done […]

Java newCachedThreadPool Example

Executor’s newCachedThreadPool factory method :

You may also like:

Get Thread Id in Java

ArrayBlockingQueue in java

Java wait seconds or delay Java program for few secs

How to print even and odd numbers using threads in java

Why wait(), notify() And notifyAll() methods are in Object Class

Custom BlockingQueue implementation in java

Difference between Runnable and Callable in java

Print sequence using 3 threads in java

Java Runnable example

Java Executor framework tutorial with example

Author

Related Posts

Difference between Runnable and Callable in java