1️⃣ 스트림이란 ?

• 컬렉션 및 배열에 저장된 요소를 반복 처리하기 위해서는 for 문을 이용하거나 Iterator(반복자)를 이용

• Java 8 부터는 컬렉션 및 배열의 요소를 반복 처리하기 위해 스트림을 이용.(스트림은 요소들이 하나씩 흘러가면서 처리된다는 의미)

  Stream<String> stream = list.stream();
  stream.forEach( item -> );
  

  → List 컬렉션의 stream() 메서드로 Stream 객체를 얻고, forEach() 메서드로 요소를 어떻게 처리할지를 람다식으로 제공.

package stream.sec01;

import java.util.HashSet;
import java.util.Set;
import java.util.stream.Stream;

public class StreamMain {
    public static void main(String[] args) {
        Set<String> set = new HashSet<>();
        set.add("홍길동");
        set.add("신용권");
        set.add("김자바");

        Stream<String> stream = set.stream();
        // 람다식 요소 처리 방법
        stream.forEach(name -> System.out.println(name));
    }
}

Stream 특징

1. 내부 반복자이므로 처리 속도가 빠르고 병렬 처리에 효율적
2. 람다식을 이용하여 다양한 요소 처리 정의 가능
3. 중간 처리와 최종 처리를 수행하도록 파이프 라인 형성 가능
   • 중간 처리 : map(), filter(), sorted()
   • 최종 처리 : forEach(), collect(), count()

2️⃣ 내부 반복자

• 외부 반복자 : 컬렉션의 요소를 컬렉션 바깥쪽으로 반복해서 가져와 처리(for문과 Iterator)
• 내부 반복자 : 요소 처리 방법을 컬렉션 내부로 주입시켜서 요소를 반복 처리(스트림)

내부 반복자는 멀티 코어 CPU를 최대한 활용하기 위해 요소들을 분배시켜 병렬 작업을 할 수 있음. 하나씩 처리하는 순차적 외부 반복자보다는 효율적으로 요소를 반복시킬 수 있는 장점

package stream.sec02;

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

public class ParallelStreamMain {
    public static void main(String[] args) {
        List<String> list = new ArrayList<>();
        list.add("a");
        list.add("b");
        list.add("c");
        list.add("d");
        list.add("e");

        Stream<String> parallelStream = list.parallelStream();
        parallelStream.forEach(name ->{
            System.out.println(name + " : " + Thread.currentThread().getName());
        });
    }
}