[Chapter 5] findAny() 는 현재 스트림에서 임의의 요소를 반환한다.

[kimjinwook1]

p.168

168페이지에서 findAny()는 현재 스트림에서 임의의 요소를 반환한다고 명시 되어 있기에 아래와 같이 코드를 작성해보았습니다.

	public static void main(String[] args) {
		List<Integer> numbers = List.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
		for (int i = 0; i < 10; i++) {
			Integer integer = numbers.stream().findAny().get();
			System.out.println("integer = " + integer);
		}
	}

코드 결과

integer = 1
integer = 1
integer = 1
integer = 1
integer = 1
integer = 1
integer = 1
integer = 1
integer = 1
integer = 1

제 예상으로는 임의의 요소를 반환한다기에 integer값이 전부 다른 결과가 나올거라 생각하였는데 몇 번을 반복하더라도 항상 첫 번째 요소만 반환합니다.
findAny()는 임의의 요소가 아닌 첫 번째 요소만 반환하는 것이 맞는건가요?

[jaeminkim90]

저도 이 내용보면서 비슷한 궁금증이 생기더라고요. 이 포스트가 비교적 쉽게 설명을 해줘서 얼추 이해하고 넘어갔습니다. 근데 재밌는 점은 병렬 스트림을 사용해서 작업을 나눠 처리할 경우에도 findFirst()는 스트림 전체의 순서를 고려하여 첫 번째 요소를 반환해준다고 하네요. 작업을 나눠 처리하더라도, 순서를 관리하는 로직이 따로 동작하는 거 같습니다. 아마 책의 후반부에 자세한 설명이 나오지 않을까 기대해봅니다ㅎㅎ 더 상세한 내용은 선아님이 설명해주실 거 같습니다!

[parks38]

findyAny() 와 같은 경우 이론 상으로는 스트림에서 랜덤한 값을 반환해 주지만
병렬이 아닌 경우에는 주로 첫번째 요소를 반환해 준다고 합니다. 하지만 이것 또한 항상 나온다고 장담할 수는 없다고 하네요.
[참고] https://www.baeldung.com/java-stream-findfirst-vs-findany

첫번째 요소를 반환해주는 이유에 대해서는 쇼트서킷(short circuit) 방식으로 결과를 찾는 즉시 실행을 중단하기 때문인 것 같습니다. 쇼트서킷 은 스트림의 모든 요소를 처리하지 않아도 조건에 부합한다면 결과를 반환 할수 있습니다.

병렬처리하지 않고 리스트에서 랜덤한 요소를 반환하려고 할때는 리스트의 첫번째 요소 부터가 조건에 부합하기에 즉시 종료되며 첫번째 요소가 계속 출력고 있습니다. 하지만 병렬처리를 통한 .findAny()를 이용한다면 첫번째 원소가 나오지 않을 뿐 아니라 이전 결과보다는 랜덤하게 나오는 것을 볼 수 있습니다.

    public static void main(String[] args) {
        String[] exampleList = {"aa", "ab", "bb", "b", "d", "f", "eee", "zz"};

        for (int i = 0; i < 10; i++) {
            String curr = Arrays.stream(exampleList)
                            .parallel()
                            .findAny()
                            .get();

            System.out.println(i + " " + curr);
        }
    }

/** 반환 결과
0 f
1 f
2 f
3 f
4 f
5 f
6 f
7 f
8 d
9 d
**/

.parallel() 했을 경우에도 저희가 생각한 것 처럼 랜덤하게 나타나지 않는것은 parallel 동작 방식인 포크앤 조인 프레임워크의 알고리즘과도 상관 있지 않을까 싶지만 조금 더 찾아보고 스터디 날까지 공부 해올 수 있다면 공유 드리겠습니다 :)

findFirst()와 findAny() 를 사용할때 병렬 실행에서는 첫번째 요소를 찾기가 어렵기에 반환 순서가 상관없으면 병렬 스트림 제약에서는 findAny()를 사용해 주는것이 포인트 인 것 같습니다.

간단하게 리스트를 가지고 findFirst() 요소를 반환하는 테스트를 진행해 보았는데
아래와 같이 parallel() 사용시에는 시간이 더 걸렸습니다.

   public static void main(String[] args) {
        String[] exampleList = {"aa", "ab", "bb", "b", "d", "f", "eee", "zz"};

        for (int i = 0; i < 3; i++) {
            long startTime = System.currentTimeMillis();
            Optional<String> curr = Arrays.stream(exampleList)
                            .parallel()
                            .findFirst();

            long finishTime = System.currentTimeMillis();

            System.out.println("parallel(ms):" + (finishTime - startTime));
        }

        System.out.println();

        for (int i = 0; i < 3; i++) {
            long startTime = System.currentTimeMillis();
            Optional<String> curr = Arrays.stream(exampleList)
                .findFirst();

            long finishTime = System.currentTimeMillis();

            System.out.println("list (ms):" + (finishTime - startTime));
        }
    }
/** 결과 값
parallel(ms):5
parallel(ms):0
parallel(ms):1

list (ms):0
list (ms):0
list (ms):0
**/