자바 스트림에서 parallel()와 sequential()을 동시에 사용하면 혼합 연산이 수행되나요? (코드있음)

Question

int sum &#61; people.stream() .parallel().filter(Person::isHasCar) .sequential().map(Person::getAge) .parallel().reduce(0, (x,y) -> x&#43;y);모던 자바 인 액션 7.1.1 파트에&#34;사실 순차 스트림에 parallel을 호출해도 스트림 자체에는 아무 변화도 일어나지 않는다. 내부적으로는 parallel을 호출하면 이후 연산이 병렬로 수행해야 함을 의미하는 불리언 플래그가 설정된다. 반대로 sequential로 병렬 스트림을 순차 스트림으로 바꿀 수 있다. 이 두 메서드를 이용해서 어떤 연산을 병렬로 실행하고 어떤 연산을 순차로 실행할지 제어할 수 있다.parallel과 sequential 두 메서드 중 최종적으로 호출된 메서드가 전체 파이프라인에 영향을 미친다. 이 예제에서 파이프라인의 마지막 호출은 parallel이므로 파이프라인은 전체적으로 병렬로 실행된다.&#34;라고 나와있는데요그래서 예시코드에 맞게 위 코드를 작성해봤습니다.그러나 인텔리제이에서&#34;Redundant 'parallel()' call: there is a subsequent 'sequential()' call which overrides this call &#34;의 알림이 발생하네요. 코드에서 sequential() 함수가 호출되었지만 그 후에 parallel() 함수가 호출되어 sequential() 호출이 무시된다는 것을 의미한다고 합니다.책의 내용을 기반으로 이해해보면filter(Person::isHasCar)는 병렬로 동작하고,map(Person::getAge)는 순차로 동작하고,reduce(0, (x,y) -> x&#43;y);는 다시 병렬로 동작하는 거로 이해를 했는데그게 아니라최종적으로 선언된 불리언 플래그에 따라서 전체 파이프라인이 좌지우지 되기 때문에혼합 연산이 아닌 최종적으로 선언된 연산에 의해 결정되는 것인가 싶어서 헷갈리네요..요약하자면...최종 메서드에 의해 전체적인 파이프라인이 어떻게 처리될지 정의되지만, 중간중간 sequential()이나 parallel()을 통해 그다음에 오는 연산에 대한 처리방식을 지정해줄 수 있다. -> 예를 들어 최종 연산이 parallel()로 선언되어 있어, 전체적인 스트림의 처리방식이 병렬로 처리를 한다고 했을 때, 중간 중간 parallel()을 넣을 필요는 없고, 순차적으로 처리할 연산이 존재할 경우 sequential()만 선언하여 혼합적으로 처리할 수 있다.최종 메서드에 의해 전체적인 파이프라인이 어떻게 처리될지 정의되기 때문에 중간중간 sequential()이나 paralllel()을 사용하더라도, 최종적으로 선언된 처리방식에 의해 파이프라인이 구축되므로 혼합적으로 처리할 수 없다.위 2개 내용 중 뭐가 옳은 것일까요?AI에 질문도 해봤는데 답이 계속 달라져서 못 믿겠네요 ㅎㅎ;;관련 자료를 찾아보곤 있는데 명확히 알고 싶어서 질문드립니다 ㅠ

kenu,전독시 · Answer

off topic인데, isHasCar 보다는 hasCar 로 바꾸는 게 어떨까요?

딥어스 · Answer

https://stackoverflow.com/questions/35742640/calling-sequential-on-parallel-stream-makes-all-previous-operations-sequential찾아본 결과 원래 변경해가면서 처리해줄 수 있던 거 같은데, 오류 발생으로 인해전체 연산을 병렬 || 순차 둘 중 하나로만 처리되도록 하는 것 같네요.혹시 위 내용이 아직까지도 유효할까요?

사과맛오렌지 · Answer

책에서도 2번, 인텔리제이도 2번을 말하고 있는데…. 어느 부분에서 혼동이 생기는 건가요..?

사과맛오렌지 · Answer

원문을 한번 찾아 봤는데, 번역가가 아예 반대로 오역을 하신 것 같습니다.Note that you might think that by combining these two methods you could achieve finer-grained control over which operations you want to perform in parallel and which ones sequentially while traversing the stream. For example, you could do something like the following:stream.parallel() .filter(...) .sequential() .map(...) .parallel() .reduce();But the last call to parallel or sequential wins and affects the pipeline globally.번역하면 이 두 메소드(sequential과 parallal)를 섞어서 쓰면 어떤 연산은 순차적으로 하고 어떤 연산은 병렬적으로 할 수 있도록 세밀한 조정을 할 수 있으리라고 생각할 수도 있다. (..sequential과 parallal을 섞어 쓰는 예시 코드..) 하지만, sequential과 parallal 호출들 중 마지막 것만이 선택되며(wins) 전체 파이프라인에 글로벌하게 적용된다."너가 이렇게 (잘못) 생각할 수도 있는데, 사실은 그렇지 않다"의 의미를 가진 문장을 완전히 반대로 해석한 것 같네요.

자바 스트림에서 parallel()와 sequential()을 동시에 사용하면 혼합 연산이 수행되나요? (코드있음)

4개의 답변

Q&A 목록