[Java] Stream

 

Stream

• Stream은 데이터를 담고 있는 저장소(컬렉션)가 아니다.
• Functional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.
• 스트림으로 처리하는 데이터는 오직 한번만 처리한다.
• 무제한일 수도 있다. (Short Circuit 메소드를 사용해서 제한할 수 있다.)
• 중개 오퍼레이션은 근본적으로 lazy하다.
• 손쉽게 병렬 처리할 수 있다.
  • .parallelStream()을 사용하면 JVM이 병렬처리
  • parallelStream을 사용한다고 무조건 빨라지는 것이 아니니 적절히 사용해야함

스트림 파이프 라인

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

중개 오퍼레이션

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

종료 오퍼레이션

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

참고

• https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html
• https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html

List<String> names = new ArrayList<>();
names.add("test");
names.add("eerojwqoe");
names.add("wqesdifnas");
names.add("eiorewer");

List<String> collect = names.stream().map((s) -> {
    System.out.println(s);
    return s.toUpperCase();
}).collect(Collectors.toList());
collect.forEach(System.out::println);

//원본 names는 변경되지 않았다
names.forEach(System.out::println);