.close()이후 poolSize문제

김영한의 실전 자바 - 고급 1편, 멀티스레드와 동시성

ExecutorService 코드로 시작하기

작성

학습하는 분들께 도움이 되고, 더 좋은 답변을 드릴 수 있도록 질문 전에 다음을 꼭 확인해주세요.

1. 강의 내용과 관련된 질문을 남겨주세요.
2. 인프런의 질문 게시판과 자주 하는 질문(링크)을 먼저 확인해주세요.
(자주 하는 질문 링크: https://bit.ly/3fX6ygx)
3. 질문 잘하기 메뉴얼(링크)을 먼저 읽어주세요.
(질문 잘하기 메뉴얼 링크: https://bit.ly/2UfeqCG)

질문 시에는 위 내용은 삭제하고 다음 내용을 남겨주세요.
=========================================
[질문 템플릿]
1. 강의 내용과 관련된 질문인가요? (예/아니오)
2. 인프런의 질문 게시판과 자주 하는 질문에 없는 내용인가요? (예/아니오)
3. 질문 잘하기 메뉴얼을 읽어보셨나요? (예/아니오)

[질문 내용]

21 버전의 자바를 사용 중입니다. .close()를 하여도 pool의 개수가 0개로 변경되지 않습니다.

main 스레드에서 인지하는데 시간이 걸리나 하여 sleep()을 통해 시간의 변화를 줬지만 여전히 동일한 결과값이 도출됩니다.

java 객체지향 동시성 multithread thread

답변 3

이재현

저도 똑같은 문제가 있었는데, 혹시 ExecutorUtils에 있는 printState에서 pool 변수가 잘못되어 있는것은 아니실까요?

public abstract class ExecutorUtils {
    public static void printState(ExecutorService executorService) {
        if(executorService instanceof ThreadPoolExecutor poolExecutor) {
            // int pool = poolExecutor.getCorePoolSize(); // 설정된 고정 최소 쓰레드 수
            int pool = poolExecutor.getPoolSize(); // 현재 풀에 살아 있는 전체 쓰레드 수
            int active = poolExecutor.getActiveCount();
            int queuedTasks = poolExecutor.getQueue().size();
            long completedTask = poolExecutor.getCompletedTaskCount();
            log("[pool=" + pool + ", active=" + active + ", queuedTasks" + queuedTasks +
                    ", completedTasks=" + completedTask + "]");
        } else {
            log(executorService);
        }
    }
}

김현수

질문자

문제 해결이 되지 않습니다.
왜 교안처럼 pool에서 대기하는 스레드들이 제거가 되지 않는 걸까요

생각하는자

작업 시간이 같아서 close가 종료 되기 전에, 상태가 호출 된거 아닌가 라는 생각 이 듭니다.
es.close() 호출 한 다음,
sleep() 으로 1초 정도 대기 한 다음에, 출력해 보시는것을 추천 드립니다.

인프런 AI 인턴

안녕하세요, 인프런 AI 인턴입니다. 김현수님.

ExecutorService를 사용하면서 .close()처럼 보이는 메서드는 존재하지 않는데, 아마도 shutdown() 또는 shutdownNow() 메서드를 뜻하시는 것 같습니다. 이들 메서드는 실행 중인 작업을 정상적으로 종료시키는 역할을 합니다. 그러나 shutdown을 호출하여도 작업이 즉시 중단되지 않을 수 있으며, 이는 현재 진행 중인 작업이 모두 완료된 후 풀의 상태가 변경되기 때문입니다.

만약 pool의 크기가 줄어들지 않는 이슈가 있다면 몇 가지 확인할 점이 있습니다:

shutdown() 메서드 확인: shutdown()은 현재 큐에 있는 작업을 모두 완료한 후 종료합니다. 반면 shutdownNow()는 큐에 있는 작업을 중단시키고 실행 중인 작업도 시도해야 합니다. 하지만 후자는 보장이 되지 않는데, awaitTermination()을 사용하셔서 좀 더 정확한 종료를 기다려 보시는 것도 좋습니다.
잠시 대기 후 종료 확인: 실제로 종료가 이루어지기까지 일정 시간이 소요될 수 있으며, awaitTermination을 통해 시간을 두고 기다려주는 방법이 있습니다.
```
es.shutdown();
if (!es.awaitTermination(60, TimeUnit.SECONDS)) {
   es.shutdownNow();
}
```
로그 확인: 위 과정을 거친 후, printState()를 사용하여 상태를 확인하는 것이 필요해 보입니다.

다음과 같은 질문 자료가 도움될 수 있습니다:
- 멀티스레드 작업 종료 그렇지만 pool 사이즈 변경 이슈
- Executor 서비스 종료 방법

문제를 해결하는 데 도움이 되었길 바랍니다.
저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

인프런 커뮤니티 질문&답변

.close()이후 poolSize문제