JAVA 8(3) - Stream API

Stream, Stream API

스트림 (Stream)

데이터의 흐름

• 스트림은 데이터 소스를 변경하지 않는다.
  • 데이터 소스로부터 데이터를 읽기만할 뿐, 데이터 소스를 변경하지 않는다. 변경된 데이터가 필요하다면 결과를 컬렉션이나 배열에 담아서 반환할 수 있다.
• 스트림으로 처리하는 데이터는 오직 한번만 처리한다.
• 무제한일 수도 있다. (실시간으로 계속 데이터를 받아 온다면 Short Circuit 메소드를 사용해서 제한해서 사용 가능)
• 중개 오퍼레이션은 근본적으로 lazy 하다.
• 손쉽게 병렬 처리(multi-threading)가 가능하다.
  • 병렬처리: 하나의 작업을 둘 이상의 작업으로 잘게 나눠서 동시에 진행하는 것

스트림 파이프라인

• 0 또는 다수의 중개 오퍼레이션(Intermediate operation)과 한개의 종료 오퍼레이션(terminal operation)으로 구성됨
• 스트림의 데이터 소스는 오직 종료 오퍼레이션을 실행할 때에만 처리됨

전체 -> 맵핑 -> 필터링1 -> 필터링2 -> 결과 만들기 -> 결과물

중개 오퍼레이션 (Intermediate operation)

• Stream을 리턴한다.
• filter, map, limit, skip, sorted …

종료 오퍼레이션 (terminal operation)

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

Stream API 실습

• OnlineClass 클래스

package java8;

public class OnlineClass {
    private Integer id;
    private String title;
    private boolean closed;

    public OnlineClass(Integer id, String title, boolean closed) {
        this.id = id;
        this.title = title;
        this.closed = closed;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public boolean isClosed() {
        return closed;
    }

    public void setClosed(boolean closed) {
        this.closed = closed;
    }
}

• 메인 클래스

package java8;

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


public class Main {

    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));

        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("spring 으로 시작하는 수업");
        // TODO
        springClasses.stream()
                .filter(oc -> oc.getTitle().startsWith("spring"))
                .forEach(oc -> System.out.println(oc.getTitle()));

        System.out.println("close 되지 않은 수업");
        // TODO
        springClasses.stream()
                .filter(Predicate.not(OnlineClass::isClosed))
                .forEach(oc -> System.out.println(oc.getTitle()));

        System.out.println("수업 이름만 모아서 스트림 만들기");
        // TODO
        springClasses.stream()
                .map(OnlineClass::getTitle)
                .forEach(System.out::println);


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

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

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


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


}

Reference

java 스트림 총정리

java8 소스코드