Parallel Streams in Java with code samples

In my earlier article, I had covered the Stream API in depth. In this article, we will be taking a look at parallel streams. Simply speaking, a parallel stream is a stream that operates on its elements in parallel.

How to obtain a parallel stream

Just like the stream method, all the Collection interfaces have a parallelStream method. This returns a parallel stream on the underlying Collection.

Consider the following code:

List<String> food = Arrays.asList("Pizza","Sandwich","Burger","Rice");Stream<String> foodStr = food.parallelStream();

This code first creates a String List food with some values. It then invokes the parallelStream method on food. This returns a String Stream which is a parallel stream.

In addition, the Stream interface also has a method parallel. If the stream on which this method is invoked is a sequential stream, it returns a parallel stream corresponding to it. If the stream on which it is invoked in a parallel stream, it returns the stream itself.

Consider the following code:

Stream<String> foodStream = Stream.of("Pizza","Sandwich","Burger","Rice");Stream<String> parallelFoodStream = foodStream.parallel();

This code first creates a String Stream foodStream using the Stream.of method. This creates a sequential stream. It then invokes the parallel method on foodStream. This returns a parallel stream corresponding to foodStream.

How parallel streams work

A parallel stream operates on the elements of the underlying stream in parallel and then combines the results at the end. This gives parallel streams a performance advantage over sequential stream. However, a word of caution. When parallel streams are used, the order of execution is not guaranteed. Hence, you should use them only for operations where the order of execution does not matter.

Consider the following code:

List<Integer> marks = Arrays.asList(81,76,69,92,84,75,88,96,54,91);List<Integer> marks2 = marks.parallelStream().filter(m -> m > 80).collect(Collectors.toList());System.out.println(marks2);

This code first creates an Integer List marks using some values. It then obtains a parallel stream on marks and invokes the filter method on the stream. The parallelStream method creates multiple smaller streams. The filter operation is performed on each stream by a separate thread. Finally, the result of performing the filter operation are combined before performing the collect operation.

This code produces the following output:

[81, 92, 84, 88, 96, 91]

Difference between a sequential and parallel stream

Now that we are familiar with parallel streams, let me list down the difference between a sequential and a parallel stream.

  1. Sequential streams use a single thread to process all the elements in the stream. Parallel streams on the other hand split the stream into smaller streams and use separate threads to process each stream.
  2. In order to obtain a sequential stream on a collection, you need to use the stream method. In order to obtain a parallel stream on a collection, you need to invoke the parallelStream method.
  3. Parallel streams are more efficient than sequential streams on multi-core processors.

Conclusion

So, in this article, we understood what parallel streams are, how one can obtain a parallel stream and the differences between a sequential and a parallel stream.

 

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