{"id":518,"date":"2013-04-14T01:53:25","date_gmt":"2013-04-14T01:53:25","guid":{"rendered":"http:\/\/choudhury.com\/blog\/?p=518"},"modified":"2013-04-14T01:53:25","modified_gmt":"2013-04-14T01:53:25","slug":"java-8-streams-intro","status":"publish","type":"post","link":"https:\/\/choudhury.com\/blog\/2013\/04\/14\/java-8-streams-intro\/","title":{"rendered":"Java 8 Streams Intro"},"content":{"rendered":"

One of the cool new features in upcoming Java 8<\/a> release is the update to the the Collections API with the new Streams API.<\/p>\n

Say if I have a Project class with an isCompleted method. If want a list of all completed projects. Now I want to retrieve a list of projects that have been completed.<\/p>\n

Using Java 6 I could do this….<\/strong><\/p>\n

List<<\/span>Project><\/span> completedProjects=<\/span>new<\/span> ArrayList<<\/span>Project><\/span>(<\/span>)<\/span>;<\/span>
\nfor<\/span> (<\/span>Project project :<\/span> allProjects)<\/span> {<\/span>
\n    if<\/span> (<\/span>project.isCompleted<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n        completedProjects.add<\/span>(<\/span>project)<\/span>;<\/span>
\n    }<\/span>
\n}<\/span><\/div><\/div>\n

The above is correct and would work, few criticism of this way, many people (especially with functional language background) would argue its very verbose for what it’s doing, the problem that I’m trying to solve is just to get the released projects – ( do I need to specify it needs to be done in a loop?).<\/p>\n

So a few issues with the above<\/p>\n

    \n
  1. Have to do the filtering using a loop, is something I shouldn’t have to decide, instead I should delegate it to library to decide the best implementation<\/li>\n
  2. The looping used above is sequential, so doesn’t take advantage of multi-cores in todays machines<\/li>\n
  3. Being pedantic, I had to mention the the type “Project” 3 times in this simple code (ok, with Java 7 Diamonds you could reduce it to 2).<\/li>\n<\/ol>\n

    The Java 8 Way of doing this would be..<\/strong><\/p>\n

    List<<\/span>Project><\/span> completedProjects =<\/span> allProjects.stream<\/span>(<\/span>)<\/span>
    \n    .filter<\/span>(<\/span>project -><\/span> project.isCompleted<\/span>(<\/span>)<\/span>)<\/span>
    \n    .collect<\/span>(<\/span>Collectors.toList<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/div><\/div>\n

    Now the stream library is free to decide if it’s going to use sequential loop or use some clever algorithm to best use the CPU on the machine. i also like the fact, I only have to mention the type “Project” once in all of this.<\/p>\n

    What confused me at first, is why the .collect is required the end. The way I think about this, is that Stream API could be applying the filter in parallel, so you need a collector at the end to pickup all of those results from the filters and place them into the result list.<\/p>\n

    The neat thing about the streams, is that you add other stuff onto the pipeline, say, I want to get the sorted list of completed projects…<\/p>\n

    List<<\/span>Project><\/span> completedProjects =<\/span> allProjects.stream<\/span>(<\/span>)<\/span>
    \n    .filter<\/span>(<\/span>project -><\/span> project.isCompleted<\/span>(<\/span>)<\/span>)<\/span>
    \n    .sorted<\/span>(<\/span>)<\/span>
    \n    .collect<\/span>(<\/span>Collectors.toList<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/div><\/div>\n","protected":false},"excerpt":{"rendered":"

    One of the cool new features in upcoming Java 8 release is the update to the the Collections API with the new Streams API. Say if I have a Project class with an isCompleted method. If want a list of all completed projects. Now I want to retrieve a list of projects that have been … <\/p>\n

    Continue reading “Java 8 Streams Intro”<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[3,17],"tags":[],"class_list":["post-518","post","type-post","status-publish","format-standard","hentry","category-java","category-lambda"],"jetpack_featured_media_url":"","jetpack_sharing_enabled":true,"_links":{"self":[{"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/posts\/518","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/comments?post=518"}],"version-history":[{"count":34,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/posts\/518\/revisions"}],"predecessor-version":[{"id":552,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/posts\/518\/revisions\/552"}],"wp:attachment":[{"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/media?parent=518"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/categories?post=518"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/choudhury.com\/blog\/wp-json\/wp\/v2\/tags?post=518"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}