JAVA - Stream 개념 및 사용법

Java에서의 Stream은 데이터 컬렉션 처리를 위한 추상화된 개념입니다.

이를 통해 데이터를 선언적으로 처리할 수 있으며, 멀티 스레딩에 대한 복잡성 없이 데이터를 병렬로 처리할 수 있는 기능을 제공합니다.

Stream은 데이터의 흐름을 나타내며, 이를 통해 데이터 컬렉션을 마치 SQL문을 이용하여 데이터베이스를 쿼리하는 것처럼 다룰 수 있습니다.

 

Stream의 주요 특징

• 비파괴적인 처리: Stream 연산은 원본 데이터를 변경하지 않습니다. 대신, 결과를 담은 새로운 Stream이 반환됩니다.
• 게으른 실행(Lazy Evaluation): Stream 연산은 실제로 값을 필요로 하는 최종 연산이 호출될 때까지 실행을 지연합니다.
• 내부 반복: Stream API는 반복을 추상화하므로, 사용자는 데이터를 어떻게 처리할 것인지에만 집중할 수 있습니다.

Stream의 주요 연산

Stream 연산은 크게 중간 연산(Intermediate operations)과 최종 연산(Terminal operations)으로 나뉩니다.

• 중간 연산: Stream을 다른 Stream으로 변환하는 연산입니다. 필터링, 매핑 등이 여기에 속합니다.
• 최종 연산: Stream 처리를 마무리하고 결과를 도출하는 연산입니다. 예를 들어, 리스트로 변환하거나, 요소들을 합산하는 작업 등이 있습니다.

예시: Stream을 이용한 리스트 처리

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

public class StreamExample {
    public static void main(String[] args) {
        List<String> names = Arrays.asList("Steve", "John", "Kim", "Anna", "Paul");

        // 이름이 4글자인 사람들만 필터링하고, 대문자로 변환한 후 리스트로 수집
        List<String> filteredNames = names.stream() // Stream 생성
                .filter(name -> name.length() == 4) // 중간 연산: 필터링
                .map(String::toUpperCase) // 중간 연산: 매핑
                .collect(Collectors.toList()); // 최종 연산: 리스트로 수집

        System.out.println(filteredNames); // 결과 출력: [JOHN, KIM, PAUL]
    }
}

 

이 예시에서는 names 리스트에서 이름이 4글자인 사람들만 골라 대문자로 변환한 다음, 그 결과를 새로운 리스트로 만들어서 출력합니다.

여기서 filter, map은 중간 연산이며, collect는 최종 연산입니다.

 

이처럼 Stream API를 이용하면 복잡한 데이터 처리 작업을 간결하고 직관적으로 수행할 수 있습니다.

데이터가 크거나, 병렬 처리가 필요한 경우에도 Stream의 병렬 처리 기능을 이용하면 성능을 크게 향상시킬 수 있습니다.