Java - 스트림(stream)

// 빨간색 사과 필터링 List<Apple> redApples = forEach(appleList, (Apple apple) -> apple.getColor().equals("RED")); // 무게 순서대로 정렬 redApples.sort(Comparator.comparing(Apple::getWeight)); // 사과 고유번호 출력 List<Integer> redHeavyAppleUid = new ArrayList<>(); for (Apple apple : redApples) redHeavyAppleUid.add(apple.getUidNum());

List<Integer> redHeavyAppleUid = appleList.stream() .filter(apple -> apple.getColor().equals("RED")) // 빨간색 사과 필터링 .sorted(Comparator.comparing(Apple::getWeight)) // 무게 순서대로 정렬 .map(Apple::getUidNum).collect(Collectors.toList()); // 사과 고유번호 출력

List<Integer> redHeavyAppleUid = appleList.parallelStream() // 병렬 처리 .filter(apple -> apple.getColor().equals("RED")) // 빨간색 사과 필터링 .sorted(Comparator.comparing(Apple::getWeight)) // 무게 순서대로 정렬 .map(Apple::getUidNum).collect(Collectors.toList()); // 사과 고유번호 출력

Consume<List<Food>> c = (foodList) -> { for (food : foodList) System.out.println(food); } c.accept(foodList); // 정상 c.accept(foodList); // 정상 Stream<Food> s = foodList.stream(); s.forEach(System.out::println); // 정상 s.forEach(System.out::println); // IlleagalStateException 발생

List<String> foodNameList = new ArrayList<>(); for (Food food : foodList){ foodNameList.add(food.getName()); } List<String> foodNameList = foodList.stream() .map(Food::getName) .collect(Collectors.toList());

String[] array = new Integer[]{1, 2, 3}; Stream<Integer> stream1 = Arrays.stream(array); Stream<Integer> stream2 = Arrays.stream(array, 1, 3); // index 1 포함, 3 제외

List<Integer> list = Arrays.asList(1, 2, 3); Stream<Integer> stream = list.stream();

Stream<Integer> stream = Stream<Integer>builder() .add(1) .add(2) .add(3) .build();

// generate 시그니처 : Supplier 함수형 인터페이스를 매개변수로 받는다. // public static<T> Stream<T> generate(Supplier<T> s) { ... } // Hello 문자열을 무한대로 생성하는 스트림 Stream<String> stream = Stream.generate(() -> "Hello").limit(5);

// 100부터 10씩 증가하는 숫자를 생성하는 iterate Stream<Integer> stream = Stream.iterate(100, n -> n + 10).limit(5);

Stream<Integer> stream = Stream.empty();

IntStream intStream = IntStream.range(1, 10); IntStream boxedIntStream = IntStream.range(1, 10).boxed(); // 오토박싱 LongStream longStream = LongStream.range(1, 100); LongStream boxedLongStream = LongStream.range(1, 100).boxed(); // 오토박싱

IntStream stream1 = "Hello, world".chars(); // (72, 101, 108, 108, 111, 44, 32, 87, 111, 114, 108, 100) Stream<String> stream2 = Pattern.compile(",").splitAsStream("Apple,Banana,Melon");

Stream<String> stream = Files.lines(Path.get("test.txt"), Charset.forName("UTF-8"));

Stream<Integer> stream1 = Stream.of(1, 2, 3); Stream<Integer> stream2 = Stream.of(4, 5, 6); Stream<Integer> stream = Stream.concat(stream1, stream2); // 1, 2, 3, 4, 5, 6

// 스트림의 Food 요소들 중 calories가 400을 넘는 값만 필터링 foodList.stream().filter(food -> food.getCalories() > 400)

// Food 컬렉션에서 생성한 스트림으로부터 food 이름들의 스트림으로 변환 foodList.stream().map(Food::getName())

// foodList 스트림 중 앞에서 10번째부터 10개의 데이터만 선택 foodList.stream().skip(10).limit(10)

foodList.stream().sorted() foodList.stream().sorted(Comparator.comparingInt(Food::getCalories))

// foodList 스트림 중 Apple 문자열을 이름에 포함하고 있는 데이터가 있는지 확인(true/false 반환) foodList.stream().anyMatch(food -> food.getName().contains("Apple"))

foodList.stream().findFirst(food -> food.getName().contains("Apple")) foodList.stream().findAny(food -> food.getName().contains("Apple"))

// 1부터 10까지의 숫자들을 하나씩 누적해서 더한다. Integer sum = Stream.of(1, 2, 3) .reduce((total, y) -> total + y); System.out.println("sum: " + s); //sum: 6 // 초기값을 지정해 줄 수 있다. Integer sum = Stream.of(1, 2, 3) .reduce(10, Integer::sum); System.out.println("sum: " + sum); //sum: 16 // 세 번째 인자로 병렬처리 결과를 합치는 로직을 받을 수 있다. Integer sum = ArrayList.asList(1, 2, 3) .parallelStream() .reduce(10, Integer::sum, (a, b) -> a + b); // sum: 36 // 여기서 36이 되는 이유는 병렬처리로 10 + 1 / 10 + 2 / 10 + 3 을 각각 계산 후 값들을 더했기 때문이다.