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

[질문 템플릿]
1. 강의 내용과 관련된 질문인가요? (예)
2. 인프런의 질문 게시판과 자주 하는 질문에 없는 내용인가요? (예)
3. 질문 잘하기 메뉴얼을 읽어보셨나요? (예)

[질문 내용]
안녕하세요.
Future의 cancel기능에 대해 실험하면서 해결하기 어려운 부분을 만나 질문드립니다.

📋실험 내용

1. Callable의 call메서드 내부에서 I/O와 같은 블로킹 작업 진행(or Interrupt가 되지 않는 작업)

2. Future의 cancel 진행

3. 스레드 호출 대상은 CancellationException 예외 발생 후 진행
   ※ 스레드 풀의 스레드는 계속 실행 중임을 확인

💥문제 사항

이런 방식으로 로직이 지속 실행되면 스레드 풀의 스레드는 종료되지 않으면서 고갈되어 가고 결국엔 작업이 쌓이다가 에러를 뱉어내고 오작동 하게 될 것이라 추측됩니다.

❓질문 내용

Q. cancel기능은 Interrupt 를 발생해주면서 작업을 중단합니다. 만약 I/O 작업 처럼 Interrupt가 먹히지 않는 로직에서는 어떻게 스레드의 실행을 종료하고 스레드 풀로 반납할 수 있을까요?

💻 코드

public class FutureCancelMain {
    private static boolean mayInterrupIfRunning = true;

    public static void main(String[] args) {
        ExecutorService es = Executors.newFixedThreadPool(1);
        Future<String> future = es.submit(new MyTask());
        log("Future.state: " + future.state());

        sleep(3000);

        log("future.cancel(" + mayInterrupIfRunning + ") 호출");
        boolean cancelResult = future.cancel(mayInterrupIfRunning);
        log("cancel(" + mayInterrupIfRunning + ") result: " + cancelResult);

        try {
            log("Future result: " + future.get());
        } catch (CancellationException e) {
            log("Future는 이미 취소되었습니다.");
        } catch (ExecutionException | InterruptedException e) {
            e.printStackTrace();
        }
        es.close();
    }

    static class MyTask implements Callable<String> {

        @Override
        public String call(){
            boolean flag = true;
//            Scanner scanner = new Scanner(System.in);
            while(flag) {
                log("무한 작업 중...");
            }
            return "Completed";
        }
    }