how to implement Parallel streams in Java 8:

-

    When you want to process the data concurrently across multiple process, what will you do???

Java 8 offers you a concept…

That is “Parallel Streams”.

The common usage of parallel Streams is listed below.

Batch Processing: Reading sensor inputs and log files can be done. These can be concurrently   

                                processed across multiple places.

Data Processing: It deals with large amount of data. It collects large amount of data, process it by

                               streams.

Data Analysis:  This process Analyse the data collected.

Image and video processing: Image and video is processed according to the standard format. It deals

                                                     with image filteration, video layout editing and so on.

Sorting, Searching and aggregation: These are operations on data. It deals with arranging the data in

                                                               specified format for sorting. Searching is a process of finding                                                                     an element. Aggregation deals with combining data together.

Machine learning: This deals with large sets of data involving machine learning algorithms.

Real time data processing: Real time data is processed concurrently.

How to create a Parallel Streams:

              As we know earlier, parallel streams are executed the process parallelly. So, it uses stream to execute this.

  • Here, there are three built in packages are used.
  • Arrays, List and Stream collectors. There are the sub packages from java.util package.
  • Create a class “StreamEg2” and save this file as “StreamEg2.java”.
  • Inside the main function, create a list as Array
  • Next, call Parallel Stream function and using ForEach method, print the value.

#Java Program to create Parallel streams

import java.util.Arrays;

import java.util.List;

import java.util.stream.Collectors;

   public class StreamEg2 {

       public static void main(String[] args) {

             

List<Integer> list = Arrays.asList(1, 2, 3, 4);

list.parallelStream().forEach(System.out::println);

}

}

Executing this, you will get the below output.

These are the ways of using ParallelStreams. These are useful in realtime applications and large data manipulation applications.

Comments

Post a Comment

Popular posts from this blog

How to create a XML DTD for displaying student details

-
Image
XML  is    e X tensible M arkup L anguage which is used to create used defined tags.  It has Elements  ( <STUDENT>) Attributes (<STUDENT id="21it21">) To create a XML file, create three files 1 ->  XML file (used to declare the user defined tags) 2 ->  DTD file (used to define the user defined tags) 3 ->  HTML file(used to display the xml file as web page) create these three files using any editor like notepad.  Student.Xml <?xml version="1.0"?> <!DOCTYPE STUDENTS SYSTEM "E:\XML1\STUDENT.dtd"> <STUDENTS>  <STUDENT>  <STUDENTDATA>     <NAME> SUTHA </NAME>     <ID>  2007IT51 </ID>     <AGE> 20 </AGE>     <ADDRESS> 12, SATHY ROAD , GOBI </ADDRESS>   </STUDENTDATA> </STUDENT> </STUDENTS> Student.dtd <?xml version="1.0"?> <!ELEMENT STU...
Read more

How to write your first XML program?

-
XML is Extensible Markup Language. It is used to create user defined tags. This is derived from SGML(Standard Generalized Markup Language). Do you like to create your own tags?? If the answer is yes, you try XML. A simple XML code is given below. It is a simple birthday message for your beloved one. < Birthday>   <Wishes>  Happy birthday  </Wishes> </Birthday>     Here, the root tag is <Birthday>. <Wishes>   is the user defined tag. This basic xml program shows you to create a root tag with elements. To create a basic program, follow the below syntax. Syntax: < ?xml version=”1.0”?> <root tag>   <element1>   </element1>                     .                     .   <elem...
Read more

Java NIO examples to illustrate channels and buffers.

-
     As the earlier blog gives you a basic knowledge about java NIO. Here, is the some examples to understand the concept of channels and buffers. Channel is a foundational construction. It helps you to connect the input, output, hardware devices, files and sockets. Buffer: it is a storage place where we can store the temporary data. Let us create a channel for processing file reading and writing operations. Make it connected with a buffer. File Reading Example using java NIO: ·        It includes the built in packages. ·        A public class is created with main() function. ·        Three objects are created. FileInputStream,FileChannel and ByteBuffer. ·        Data is read through the channel and gets stored in buffer. ·        Until the buffer has data, it reads the data and display it in the output screen · ...
Read more