[모던 자바 인 액션] 3주차

[so3500]

스터디 날짜

2023.07.13 목 20-21

내용

챕터5. 스트림 활용
챕터6. 스트림으로 데이터 수집

공유

최승위

• https://www.loom.com/share/c6543a16c0a143ba82932426f8887870?sid=9061bc99-d51f-407d-8429-4174da9bf39f

이성온

• https://www.loom.com/share/3e63ade080864bf29bbd413f86b06e4e?sid=4d752fe6-576f-4936-b5a7-85190f9f3de7

정민교

• https://github.com/LandvibeDev/stream-quiz

[so3500]

import static org.assertj.core.api.AssertionsForClassTypes.*;

import java.util.stream.Stream;

import org.junit.jupiter.api.Test;

class StreamReduceTest {

	@Test
	void reduceSum() {
		Stream<Integer> numbers = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

		// 0 + 1 + 2 + 3 + 4 + ... + 10
		Integer sum = numbers.reduce(0, (total, n) -> total + n); // Integer::sum

		assertThat(sum).isEqualTo(55);
	}

	@Test
	void reduceMinus() {
		Stream<Integer> numbers = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

		// 0 - 1 - 2 - 3 - 4 - ... - 10
		Integer sum = numbers.reduce(0, (total, n) -> total - n);

		assertThat(sum).isEqualTo(-55);
	}

	@Test
	void reduceSumParallel() {
		Stream<Integer> numbers = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

		// 0 + (1 + 2) + (3 + 4) + ... + (9 + 10)
		Integer sum = numbers.parallel().reduce(0, (total, n) -> total + n); // Integer::sum

		assertThat(sum).isEqualTo(55);
	}

	@Test
	void reduceMinusParallel() {
		Stream<Integer> numbers = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

		// 0 - (1 - 2) - (3 - 4) - ... - (9 - 10)
		Integer sum = numbers.parallel().reduce(0, (total, n) -> total - n);

		assertThat(sum).isEqualTo(-5); // -55
	}

	@Test
	void reduceMinusParallelCombine() {
		Stream<Integer> numbers = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

		// 0 - 1 - 2 - 3 - 4 - ... - 10
		// 첫번째 연산의 결과가 다음 연산에 영향을 주기 때문에 나눠서 작업을 처리할 수 없게됨
		Integer sum = numbers.parallel().reduce(0,
			(total, n) -> total - n,
			(total1, total2) -> total1 + total2); // Integer::sum / 병렬 처리된 결과들의 관계를 설정함

		assertThat(sum).isEqualTo(-55);
	}
}