자바의 다양한 기능들 3.스트림 Stream

 

스트림이란?

- 자료, 컬렉션, 배열등이 모여있을때, 이 자료들의 연산을 한다고 했을때 연산들의 처리를 추상화(일관성있게) 한 것(동일한 방식으로 연산될 수 있도록)

• 자료의 대상과 관계없이 동일한 연산을 수행
• 일관성 있는 연산으로 자료의 처리를 쉽고 간단하게 함
• 자료 처리에 대한 추상화가 구현되었다고 함
• 배열, 컬렉션(스트림메소드 호출가능 : .stream하면 스트림객체 생성가능)을 대상으로 연산을 수행 함

• 한번 생성하고 사용한 스트림은 재사용 할 수 없음
• 다른 연산을 수행하기 위해서는 스트림을 다시 생성해야 함
• 자료에 대한 스트림을 생성하여 연산을 수행하면 스트림은 소모됨

import java.util.Arrays;

public class IntArrayStreamTest {
    public static void main(String[] args) {
        int[] arr = {1,2,3,4,5};
        for(int num :arr){ //num 하나씩 출력
            System.out.println(num);
        }
        // 스트림 생성방법
        Arrays.stream(arr).forEach(n->System.out.println(n)); 
        //이 stream은 여기서한번 사용되고 재사용될 수 없음 (이후 다른연산을 하고싶다면 다시 stream 생성해야됨)
        //forEach : 요소들을 하나씩 꺼내라 (요소들의 역할 : ()안에 람다식으로 씀)
    }
}

• 스트림연산은 기존 자료를 변경하지 않음 ex.배열을 sorting한 결과를 출력한다고해서 배열 자체가 sorting되는게 아님
• 자료에 대한 스트림을 생성하면 스트림이 사용하는 메모리 공간은 별도로 생성되므로 연산이 수행되도 기존 자료에 대한 변경은 발생하지 않음

• 스트림 연산은 중간 연산과 최종 연산으로 구분 됨. 최종연산이 호출되어야 중간 연산에 대한 수행이 이루어 지고 그 결과가 만들어짐. 이를 '지연 연산'이라 함 -> 따라서 중간 연산에 대한 결과를 연산 중에 알수 없음
• 스트림에 대해 중간 연산은 여러 개의 연산이 적용될 수 있지만 최종 연산은 마지막에 한 번만 적용됨

 

 

중간연산과 최종연산

• 중간연산의 예 : filter() - 어떤조건에 해당되는 요소만 추출하는것 / map() / sorted()
• 조건에맞는 요소를 추출(filter)하거나 요소를 반환(map)함
• 최종연산이 호출될때 중간연산이 수행되고 결과가 생성됨
• 중간연산과 최종연산에 대한 구현은 람다식(익명클래스로 구현됨)을 활용함

• 최종연산의 예 : forEach() - 요소를 하나씩 꺼내옴 / count() - 요소의 개수 / sum() - 요소들의 합 등
• 스트림이 관리하는 자료를 하나씩 소모해가며 연산이 수행됨
• 최종연산후 스트림은 더이상 다른연산을 적용할수 없음

 

ArrayList객체에 스트림 생성하고 사용하기 (예제)

: Array List에 문자열 자료를 넣고 이에대한 여러연산을 수행해보기

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Stream;

public class ArrayListStreamTest {

	public static void main(String[] args) {
		List<String> sList = new ArrayList<String>();
		sList.add("Tomas");
		sList.add("Edward");
		sList.add("Jack");
		
		Stream<String> stream = sList.stream();
		stream.forEach(s->System.out.print(s + " "));
		System.out.println();
		
		sList.stream().sorted().forEach(s->System.out.print(s+ " "));
		sList.stream().map(s->s.length()).forEach(n->System.out.println(n)); //5 6 4
		sList.stream().filter(s->s.length() >= 5).forEach(s->System.out.println(s));
		
	}

}