목차

스트림이란 무엇인가?

• 스트림은 자바 API에 새로 추가된 기능으로, 스트림을 이용하면 선언형(즉, 데이터를 처리하는 임시 구현 코드 대신 질의로 표현할 수 있다.)
• 데이터를 투명하게 병렬로 처리할 수 있다.

// 기존 자바 코드
// 누적 자료 필터링
List<Dish> lowCaloricDishes = new ArrayList<>();
for(Dish d : menu) {
  lowCaloricDishes.add(d);
}
// 익명 클래스로 요리 정렬
Collections.sort(lowCaloricDishes, new Comparator<Dish>() {
  public int compare(Dish dl, Dish d2) {
    return Integer.compare(dl.getCalories(), d2.getCalories());
  }
});
// 정렬된 리스트를 처리하면서 요리 이름 선택
List(String> lowCaloricDishesName = new ArrayList<>();
for(Dish d : lowCaloricDishes) {
  lowCaloricDishesName.add(d.getName());
}

// 최신 자바 8 코드
List<String> lowCaloricDishesName =
                menu.stream()
                        .filter(d -> d.getCalories() < 400)
                        .sorted(comparing(Dish::getCalories))
                        .map(Dish::getName)
                        .collect(toList());            

• 선언형으로 코드를 구현할 수 있다.
• 이전 코드보다 쉽게 구현할 수 있다.
• 여러 빌딩 블록 연산을 연결해서 복잡한 데이터 처리 파이프라인을 만들 수 있다.

http://drive.google.com/uc?export=view&id=0ByLqiEM75qEzMFFJVVI0bGRuVk0

파이프라인

• 우리는 데이터 처리 과정을 병렬화하면서 스레드와 락을 걱정할 필요가 없다.
• 스트림 API특징
  • 선언형 : 더 간결하고 가독성이 좋아진다.
  • 조립할 수 있음 : 유연성이 좋아진다.
  • 병렬화 : 성능이 좋아진다.

스트림 시작하기

• 스팀림이란 ’데이터 처리 연산을 지원하도록 소스에서 추출된 연속된 요소’로 정의할 수 있다.
• 연속된 요소
  • 컬렉션은 자료구조이므로 컬렉션에서는 요소 저장 및 접근 연산이 주로 이룬다.
  • 스트림은 filter, sorted, map처럼 표현 계산식이 주를 이룬다.
  • 즉, 컬렉션은 주제는 데이터, 스트림의 주제는 계산이다.
• 데이터 처리 연산
  • 스트림은 데이터베이스와 비슷한 연산을 지원한다. 스트림 연산은 순차적으로 또는 병렬로 실했할 수 있다.
• 파이프라이닝
  • 대부분의 스트림 연산은 스트림 연산끼리 연결해서 커다란 파이프라인을 구성할 수 있도록 스트림 자신을 반환한다.
• 내부 반복
  • 내부반복을 지원한다.
• filter
  • 람다를 인수로 받아 스트림에서 특정 요서를 제외시킨다.