Java8 Stream

Stream 이란?

• 컬렉션, 배열등에 대해 저장되어있는 요소들을 하나씩 참조하며 반복적인 처리를 가능하게 하는 기능이다.
• Stream을 이용한다면 불필요한 for문과 그 안에서 이루어지는 if문 등의 분기 처리를 쓰지 않고도 깔끔하게 직관적인 직관적인 코드로 변형할 수 있다.

 

Stream API 사용법

Stream API는 데이터, Stream생성(), 중개연산()...종료연산(); 구조로 사용된다.

 

Stream 특징

• 데이터를 담고 있는 저장소 (컬렉션)이 아니다
• Funtnional in nature 스트림이 처리하는 데이터 소스를 변경하지 않는다
• 스트림으로 처리하는 데이터는 오직 한번만 처리한다
• 무제한일 수도 있다(Short Circuit 메소드를 사용해서 제한할 수 있다
• 중개 오퍼레이션은 근본적으로 lazy하다
• 손쉽게 방렬 처리할 수 있다

 

스트림 파이프라인

• 0 또는 다수의 중개 오퍼레이션(intermediate opratinfo과 한 개의 종료 오퍼레이션으로 구성되어있다
• 스트림의 데이터 소스는 오직 터미널 오퍼네이션을 실행할 때에만 처리한다

 

중개 오퍼레이션

• Stream을 리턴한다
• Stateless / Stateful 오퍼레이션으로 더 상세하게 구분할 수도 있다. 대부분은 Stateless지만 distinct나 sorted처럼 이전 이전 소스 데이터를 참조해야 하는 오퍼레이션 Statefil 오퍼레이션이다.
• filter, map, skip, sorted

 

종료 오퍼레이션

• Stream을 리턴하지 않는다
• collect, allMatch, count, forEach, min, max

 

 

 

Stream 실습

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class App {
    public static void main(String[] args) {

        List<OnlineClass> springClasses = new ArrayList<>();
        springClasses.add(new OnlineClass(1, "spring boot", true));
        springClasses.add(new OnlineClass(2, "spring data jpa", true));
        springClasses.add(new OnlineClass(3, "spring mvc", false));
        springClasses.add(new OnlineClass(4, "spring core", false));
        springClasses.add(new OnlineClass(5, "rest api development", false));


        System.out.println ("spring 으로 시작하는 수업");
        springClasses.stream ().filter(oc -> oc.getTitle ().startsWith ("spring"))
                        .forEach(oc -> System.out.println (oc.getId()));

        System.out.println ("close 외지 않은 수업");
        springClasses.stream().filter(oc -> !oc.isClosed())
                              .forEach(oc -> System.out.println (oc.getId()));

        System.out.println ("수업 이름만 모아서 스트림 만들기");
        springClasses.stream().map(oc -> oc.getTitle())
                .forEach(s -> System.out.println(s));

        List<OnlineClass> javaClasses = new ArrayList<> ();
        javaClasses.add(new OnlineClass(6,"The Java, Test", true));
        javaClasses.add(new OnlineClass(7,"The Java, Code manipulation", true));
        javaClasses.add(new OnlineClass(8,"The Java, 8 to 11", false ));


        List<List<OnlineClass>> keesunEvents = new ArrayList<>();

        keesunEvents.add(springClasses);
        keesunEvents.add(javaClasses);

        System.out.println ("두 수업 목록에 들어있는 모든 수업 아이디 출력");
        keesunEvents.stream().flatMap( Collection::stream)
                        .forEach(oc -> System.out.println(oc.getId()));

        System.out.println ("10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만");
        Stream.iterate(10, i -> i + 1)
                .skip(10)
                .limit(10)
                .forEach( System.out::println);


        System.out.println ("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
        boolean test = javaClasses.stream ().anyMatch ( oc -> oc.getTitle ().contains ( "Test" ) );
        System.out.println(test);


        System.out.println("스프링 수업 중에 제목에 spring이 들어간 제목만 모아서 List로 만들기");
        List<String> spring = springClasses.stream ().filter ( oc -> oc.getTitle ().contains ( "spring" ) )
                .map (OnlineClass::getTitle)
                .collect (Collectors.toList());
        spring.forEach(System.out::println);
    }
}

 

 

 

참고

---

• https://docs.oracle.com/javase/8/docs/api/java/util/Optional.html
• 백기선 - 더 자바, Java8