pararellStream, ForkJoinPool 질문이 있습니다!

Question

이번에 특정 api의 특정 클래스 메서드에서 속도가 1분 이상이 경과되서 확인해보니 stream 을 사용하고 있었습니다.그래서 pararellStream 을 활용해보았는데요. 속도가 확실시 1분에서 -> 10초대로 낮아졌습니다.근데 찾아보니 pararellStream 은 별도의 설정이 없다면 하나의 Thread Pool을 모든 parallelStream이 공유하게 되고, Thread Pool을 사용하는 다른 Thread에 영향을 줄 수 있으며, 반대로 영향을 받을 수 있다. 라고 되어있어 아래와 같이 ForkJoinPool forkJoinPool &#61; new ForkJoinPool(6)를 활용하였습니다. -> 단독 스레드풀 생성 및 스레드 갯수 설정가능public void sum(){ForkJoinPool forkJoinPool &#61; new ForkJoinPool(6)forkJoinPool.submit(() -> data.parallelStream().forEach(u -> {.....forkJoinPool.shotdown();}근데 이 객체생성부분을 메서드 내에 선언해두면 사용자가 몰려서 한번에 해당 메서드를 사용하는 api가 10번 호출되면객체가 10개 생성될거고 -> 스레드풀 10개, 스레드가 60개가 생성되어 서버 메모리에 부하가 올 것 같다고 판단을했습니다.근데 또 검색해보니 ForkJoinPool 클래스의 인스턴스는 한번생성되면 더이상 생성되지않고 공유한다고? 되어져있더라구요..그래서 api 가 10 번호출되어도 1개의 스레드풀과 그 내의 6개 스레드로 작업을 할것이라고 되어져있더라구요..뭐가 정확히 맞는지를 잘 모르겠습니다.혹시 아시는분 계시면 지식 공유좀 부탁드리겠습니다..감사합니다!

집킨 · Accepted Answer

API가 10번 호출되면 10개의 풀이 만들어지는게 맞습니다그리고 그냥 병렬 스트림 쓰는게 좋습니다병렬 스트림이 내부적으로 ForkJoinPool의 common pool을 사용하는데 이건 static 이라서 모든 병렬 스트림이 공유하는건 맞지만, 각 병렬 스트림이 작업을 fork해서 queue에 넣어두면 하던 작업이 끝나서 할일이 없는 common pool의 스레드들이 작업을 가져가서 처리하는 방식이기 때문에 다른 병렬 스트림 때문에 큰 영향받을일은 없습니다그럴거 같으면 웹플럭스는 뜨지도 못했겠죠진짜 병렬 스트림을 사용하는 API의 tps가 너무 많아서 미칠 지경이면 common pool의 사이즈를 늘리면 됩니다

Clickin · Answer

해당 메서드가 존재하는 bean의 static으로 선언해두시면 안전할겁니다.빈 클래스로딩 과정에서 스레드 풀을 생성할거니까요.

pararellStream, ForkJoinPool 질문이 있습니다!

2개의 답변

#stream 목록