Java/Java8

[Java8] Stream API

메성 2021. 8. 14. 16:22
반응형
 

더 자바, Java 8 - 인프런 | 강의

자바 8에 추가된 기능들은 자바가 제공하는 API는 물론이고 스프링 같은 제 3의 라이브러리 및 프레임워크에서도 널리 사용되고 있습니다. 이 시대의 자바 개발자라면 반드시 알아야 합니다. 이

www.inflearn.com

스트림

  • 데이터를 담고 있는 저장소(컬렉션)이 아니다.
  • 스트림이 처리하는 데이터 소스를 변경하지 않는다. 
    • List<String> names = new ArrayList<>();
names.add("mesung");
names.add("ms");
names.add("11st");

Stream<String> stringStream = names.stream().map(String::toUpperCase);
//대문자로 변경하는 로직을 태워도 names의 근본 값들은 변경되지 않는다.
  • 스트림으로 처리하는 데이터는 오직 한번만 처리한다.
    • 컨베이어 벨트처럼 한번 지나가면 끝!
  • 무제한일 수도 있다. 단 Short Circuti 메소드를 사용해서 몇개의 리스트만 보겠다라고 제한을 들 수도 있다.)
  • 스트림에는 중간 연산와 종료 연산가 있으며, 중간 단계의 경우 근본적으로 lazy하다. 
    • List<String> names = new ArrayList<>();
names.add("mesung");
names.add("ms");
names.add("11st");

names.stream()
  .map(s -> {
    System.out.println(s);
    return s.toUpperCase(Locale.ROOT);
  });

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

//결과
//==========
    • lazy한다는 의미는 중간 연산의 경우 종료 연산을 만날 때까지는 실행하지 않고 정의만 한 것이다.
    • 즉, 스트림 파이프 라인을 정의해야 한다! -> 중간 연산와 종료 연산의 조합(무조건 종료 연산이 있어야한다.)
    • public static void main(String[] args) {
  List<String> names = new ArrayList<>();
  names.add("mesung");
  names.add("ms");
  names.add("11st");

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

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

//결과
//mesung
//ms
//11st
//MESUNG
//MS
//11ST
//==========
  • 손쉽게 병렬 처리를 할 수가 있다.

스트림 파이프라인

  • 0 또는 다수의 중간 연산과 한개의 종료 연산으로 구성되어 있다.
  • 스트림의 데이터 소스는 반드시 종료 여난이 실행될 때만 처리된다.

중간 연산

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

종료 연산

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

스트림 사용 예제

문제

직접 풀어보시고 아래 답변 확인하시면 도움이 될 겁니다.

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("===================");
        System.out.println("spring 으로 시작하는 수업");

        System.out.println("===================");
        System.out.println("close 되지 않은 수업");

        System.out.println("=========메서드 레퍼런스 사용==========");
        System.out.println("close 되지 않은 수업");

        System.out.println("===================");
        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("===================");
        System.out.println("두 수업 목록에 들어있는 모든 수업 아이디 출력");
        // TODO

        System.out.println("===================");
        System.out.println("10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만");
        // TODO

        System.out.println("===================");
        System.out.println("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
        // TODO

        System.out.println("===================");
        System.out.println("스프링 수업 중에 제목에 spring이 들어간 것만 모아서 List로 만들기");
        // TODO

    }
}

 

예제 답변

더보기

 

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

        System.out.println("===================");
        System.out.println("close 되지 않은 수업");
        springClasses.stream()
                .filter(onlineClass -> !onlineClass.isClosed())
                .forEach(onlineClass -> System.out.println(onlineClass.getId()));
        System.out.println("=========메서드 레퍼런스 사용==========");
        springClasses.stream()
                .filter(Predicate.not(OnlineClass::isClosed))
                .forEach(onlineClass -> System.out.println(onlineClass.getId()));

        System.out.println("===================");
        System.out.println("수업 이름만 모아서 스트림 만들기");
        springClasses.stream()
                .map(onlineClass -> 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("===================");
        System.out.println("두 수업 목록에 들어있는 모든 수업 아이디 출력");
        //me
        keesunEvents.stream()
                .flatMap(list -> list.stream())
                .forEach(onlineClass -> System.out.println(onlineClass.getId()));

        //keesun
        keesunEvents.stream()
                .flatMap(Collection::stream)
                .forEach(onlineClass -> System.out.println(onlineClass.getId()));


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

        System.out.println("===================");
        System.out.println("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
        //me
        keesunEvents.stream()
                .flatMap(list -> list.stream())
                .filter(onlineClass -> onlineClass.getTitle().contains("Java"))
                .filter(onlineClass -> onlineClass.getTitle().contains("Test"))
                .map(onlineClass -> onlineClass.getTitle())
                .forEach(System.out::println);

        //keesun
        boolean test = javaClasses.stream()
                .anyMatch(onlineClass -> onlineClass.getTitle().contains("Test"));
        System.out.println(test);

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

        //keesun
        List<String> springTitle = springClass.stream()
                .filter(onlineClass -> onlineClass.getTitle().contains("spring"))
                .map(onlineClass -> onlineClass.getTitle())
                .collect(Collectors.toList());
        springTitle.forEach(System.out::println);

    }
}
  • flatMap : 다중 리스트를 단일 리스트로 변경할 수 있는 중간 단계
반응형
저작자표시