Java Callable Interface Explained with Code Samples

In this article, I will be explaining the Callable interface in Java. I will be explaining what is Runnable and Callable in Java and what is the use of the Callable interface.

Runnable Interface

Right from the start, the Runnable interface has been associated with multi-threaded programming.  The Runnable interface provides a run method that executes code in a separate thread. The following code demonstrates this:

public class RunnableDemo {  public static void main(String[] args) {    System.out.println("Creating new thread in main");    Runnable r = () -> System.out.println("Executing thread body....");    Thread myThread = new Thread(r);    myThread.start();    System.out.println("Completed main");  }}

So this code first creates a new Runnable interface and uses a lambda expression to implement the run method.  The code then creates a new Thread and invokes the start method which spawns a new Thread and executes the code in the Runnable implementation.

The downside of this approach is that you have no way of knowing when the Thread completes. Also, there is no way of returning a value from the run method.

What is Java Callable Interface?

Java 5 introduced a new interface called Callable to overcome the limitations of the Runnable interface. This interface is similar to Runnable and you can use it to spawn a new Thread. It has a method called “call”. In addition to executing code in a new Thread, you can also use this interface to return a value. The following code demonstrates this:

public class CallableDemo {  public static void main(String[] args) throws InterruptedException, ExecutionException {    System.out.println("Creating new thread in main");    Callable<String> callable = () -> {System.out.println("Executing thread body....");                        return "Hello World";                       };    FutureTask<String> task = new FutureTask<String>(callable);    Thread myThread = new Thread(task);    myThread.start();    String result = task.get();    System.out.println("Result:"+result);    System.out.println("Completed main");  }}

So this code creates a Callable which returns a result of type String. The call method is implemented via a lambda expression that returns the String “Hello World”.

Java 5 has added a FutureTask class to the concurrency API. This accepts as parameter a Callable instance. The code then creates a new Thread and passes the FutureTask as a parameter. The code then starts the Thread. The FutureTask has a method get, the code invokes this to obtain the result from the Thread. So this code prints the following output:

Creating new thread in mainExecuting thread body....Result:Hello WorldCompleted main

Callable With Executors

The Callable interface is mostly used with the Executor framework and uses a Future to obtain a result. The Executor framework is part of the Concurrency API added in Java 5. The following code demonstrates this:

public class CallableWithExecutorDemo {  public static void main(String[] args) throws InterruptedException, ExecutionException {    Callable<String> callable = () -> {      System.out.println("In Thread");      return "Hello World";    };    System.out.println("Starting new Thread");    ExecutorService executorService = Executors.newSingleThreadExecutor();    Future<String> future = executorService.submit(callable);    System.out.println("Retrieving Result...");    String result = future.get(); // this blocks till result is available    System.out.println("Result=" + result);    executorService.shutdown();  }}

As before, this code creates a Callable which returns a result of type String. The call method is implemented via a lambda expression that returns the String “Hello World”.

The code then creates a new ExecutorService. ExecutorService is part of the Executor framework, explaining it in detail here would be beyond the scope of this article. The code then invokes the ExecutorService.submit method with the Callable instance which spawns a new Thread. The ExecutorService.submit method returns a Future instance that holds the result of the computation. The Future interface has a method called get which waits for the thread to complete and then returns the result.  So this code prints the following output:

Starting new ThreadRetrieving Result...In ThreadResult=Hello World

 

Conclusion

So in this article, we saw learned about the Java Callable interface and how you can use it to obtain the results of computation from a separate thread.

Comments

Post a Comment

Popular posts from this blog

How to use logging in SpringBoot with code samples

Image
In this article, we will learn how to use logging in SpringBoot. Introduction There are several Java logging frameworks like logback, log4j, and so on. Spring Boot supports out-of-the-box support for logback. Let us learn how to use logging in SpringBoot with logback. Step 1 – Create a New Maven Project Create a new Maven project. (Refer to  this  blog post). This will create a project in Eclipse as follows:   Step 2 – Add the Spring Boot Dependencies Add the spring-boot-starter-web dependency to the pom.xml . So, the pom.xml should look as follows: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.learnjava</groupId> <artifactId>learnjava-springboot-logging-example</artifactId> <version>0.0.1-SNAPSHOT&
Read more

Python While Loop with code samples

Much like a Java while loop, you can use a Python while loop to repeatedly execute a block of code as long as a condition is true. In this article, we will learn more about the Python while loop. Python While loop Syntax A while loop in Python has the following syntax: while <condition>: loop body The while keyword is followed by a condition. If the condition evaluates to true, the body of the loop is executed. Once the body of the loop is completed, the condition is checked again and this is repeated until the condition evaluates to false at which point the loop is exited. While loop Sample Code The following code demonstrates how you can use the while loop: num=10counter=1total=0while counter<=num: total += counter counter+=1print("sum of first 10 numbers is",total) This code adds the numbers from 1 to 10 and prints the sum. It uses a while loop to iterate from 1 to 10. The while loop checks the condition counter <= num and if so adds the current value of count
Read more

How to convert a List to a Set

In this blog post ,I will be showing you how you can convert a List to a Set. Consider the following code snippet: public class ListToSetDemo {public static void main(String[] args) {List<Integer> list = Arrays.asList(5,3,11,15,9);//Method 1Set<Integer> set = new HashSet<Integer>(list);System.out.println("Set is "+set);//method 2Set<Integer> set2 = new HashSet<Integer>();set2.addAll(list);System.out.println("Set is "+set2);}} This code demonstrates two ways to convert a List to a Set. Method 1 Here, we are creating a new HashSet . We are invoking the constructor that accepts a Collection object. Here, we are passing in the input list to this constructor.   Method 2 Here again, we are creating a new HashSet . However, we are using the default constructor. We are then invoking the addAll method and passing in the input list.   When you run this code, it will print the following output: Set is [3, 5, 9, 11, 15]Set is [3, 5, 9, 11, 15] No
Read more