[java 8] 3. Stream

목차

1. Stream

2. Stream API

 

 

 

1. Stream

1) Stream 

• sequence of elements supporting sequential and parallel aggregate operations
• 데이터를 담고 있는 저장소(컬렉션)가 아니다.
• Funtional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.
• 스트림으로 처리하는 데이터는 오직 한번만 처리한다.
• 무제한일 수도 있다. (Short Circuit 메소드를 사용해서 제한할 수 있다.)
• 중개 오퍼레이션은 근본적으로 lazy 하다.

List<String> names = new ArrayList<>();
names.add("mandy");
names.add("hongseok");
names.add("keesun");
names.add("toby");

// 중계형 오퍼레이션
// 데이터가 모든 오퍼레이션을 한번만 사용하고
// 종료 오퍼레이션이 있어야 실행된다.
names.stream().map(s -> {
    System.out.println(s); // 출력되지 않음
    return s.toUpperCase();
});

System.out.println("=====================");

// 종료형 오퍼레이션
List<String> collect = names.stream().map(s -> {
    System.out.println(s);
    return s.toUpperCase();
}).collect(Collectors.toList());
collect.forEach(System.out::println);

System.out.println("=====================");

// 원본 데이터를 바꾸지 않는다.
names.forEach((name) -> System.out.println(name));
names.forEach(System.out::println);

• 손쉽게 병렬 처리할 수 있다. (parallelStream)

List<String> names = new ArrayList<>();
names.add("mandy");
names.add("hongseok");
names.add("keesun");
names.add("toby");

List<String> collect = names.parallelStream().map(s -> {
    System.out.println(s + " " + Thread.currentThread().getName());
    return s.toUpperCase();
}).collect(Collectors.toList());
collect.forEach(System.out::println);

 

2) Stream 파이프라인

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

names.stream().map(s -> {
    System.out.println(s); // 출력되지 않음
    return s.toUpperCase();
});

 

3) 중개 오퍼레이션

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

4) 종료 오퍼레이션

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

 

2. Stream API

1) 걸러내기

filter(Predicate)
예) 이름이 3글자 이상인 데이터만 새로운 스트림으로

2) 변경하기

map(Function) 또는 flatMap(Function)
예) 각각의 Post 인스턴스에서 String title만 새로운 스트림으로
예) List<Stream<String>>을 String의 스트림으로

 

3) 생성하기

generate(Supplier) 또는 Iterate(T seed, UnaryOperator)
예) 10부터 1씩 증가하는 무제한 숫자 스트림
예) 랜덤 int 무제한 스트림

 

4) 제한하기

limit(long) 또는 skip(long)
예) 최대 5개의 요소가 담긴 스트림을 리턴한다.
예) 앞에서 3개를 뺀 나머지 스트림을 리턴한다.

 

5) 스트림에 있는 데이터가 특정 조건을 만족하는지 확인

anyMatch(), allMatch(), nonMatch()
예) k로 시작하는 문자열이 있는지 확인한다. (true 또는 false를 리턴한다.)
예) 스트림에 있는 모든 값이 10보다 작은지 확인한다.

 

6) 개수 세기

count()
예) 10보다 큰 수의 개수를 센다.

 

7) 스트림을 데이터 하나로 뭉치기

reduce(identity, BiFunction), collect(), sum(), max()
예) 모든 숫자 합 구하기
예) 모든 데이터를 하나의 List 또는 Set에 옮겨 담기

 

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.getTitle()));

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

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

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 = " + test);

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

 

 

 

 

 

출처

https://www.inflearn.com/course/the-java-java8 더 자바, Java 8(백기선)