Future cancel기능을 사용했지만 interrupt가 발생하지 않을 때 어떻게 처리해야하나요?
73
4 asked
[질문 템플릿]
1. 강의 내용과 관련된 질문인가요? (예)
2. 인프런의 질문 게시판과 자주 하는 질문에 없는 내용인가요? (예)
3. 질문 잘하기 메뉴얼을 읽어보셨나요? (예)
[질문 내용]
안녕하세요.Future의 cancel기능에 대해 실험하면서 해결하기 어려운 부분을 만나 질문드립니다.
📋실험 내용
Callable의call메서드 내부에서I/O와 같은블로킹작업 진행(orInterrupt가 되지 않는 작업)Future의cancel진행스레드 호출대상은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";
}
}
Answer 2
1
안녕하세요. dltkdcksqkqh님
AI 인턴이 잘 답해주었는데요. 내용을 조금 더 보충하자면
작성하신 코드와 같이 CPU 연산 및 무한 루프 작업일 경우에는 인터럽트가 불가능합니다.
이 경우 작업자가 주기적으로 자신의 인터럽트 상태를 확인하고, 취소 요청이 들어왔으면 스스로 작업을 중단하도록 다음과 같이 코드를 작성해야 합니다.
static class MyTask implements Callable<String> {
@Override
public String call() {
log("작업 시작...");
// 1. while 루프 조건에 Thread.currentThread().isInterrupted() 추가
// 인터럽트 신호가 오면 루프를 탈출합니다.
while (!Thread.currentThread().isInterrupted()) {
log("무한 작업 중...");
// (선택 사항) I/O나 기타 로직이 있다면 이 안에서 처리
// 만약 이 안에서 무거운 로직이 있다면 중간중간 isInterrupted()를 확인하는 것이 좋습니다.
}
log("인터럽트가 감지되어 작업을 안전하게 종료합니다.");
return "Cancelled or Completed";
}
}감사합니다.
0
안녕하세요, 인프런 AI 인턴입니다. dltkdcksqkqh님.
Future의 cancel 기능을 어떤 식으로 사용해야 하는지에 대한 질문을 주셨네요. Future.cancel(true)는 해당 callable이 실행 중인 경우 인터럽트를 발생시켜 스레드를 중단시키려고 하지만, I/O 작업과 같은 블로킹 작업에서는 인터럽트가 즉시 작동하지 않을 수 있습니다. 이와 관련된 문제는 코드를 설계할 때 비동기 작업을 효율적으로 관리하는 것이 중요하다는 점을 시사합니다.
스레드 관리와 인터럽트 처리
인터럽트 가능한 작업으로 제한하기: 수행하는 작업이 가능하면
Interrupt를 통해 중단될 수 있도록 설계하는 것이 좋습니다.I/O작업 중에서도 일부는NIO(New I/O)의Channel을 사용하여 인터럽트가 가능한 상태로 변환할 수 있습니다.중단 플래그 사용하기: 스레드의 중단 여부를 인지하고 블로킹 상태를 피하기 위해 플래그를 사용할 수 있습니다. 이 방법은 긴 작업이 블록 중인지 확인할 수 있는 경우 적합합니다. 즉, 주기적으로 작업을 체크하고 인터럽트가 발생하지 않는 경우를 대비해 중단 플래그를 삽입하는 것입니다.
자주 체크하는 루프 대기 추가하기: 길게 블로킹되는 작업 앞에 주기적으로 인터럽트를 판단할 수 있도록
Thread.sleep()이나 다른 대기 코드를 추가하는 방법이 있습니다.
@Override
public String call() {
boolean flag = true;
while (flag) {
if (Thread.currentThread().isInterrupted()) {
log("인터럽트 되었습니다. 종료...");
break;
}
log("무한 작업 중...");
try {
Thread.sleep(100); // 주기적으로 인터럽트를 체크
} catch (InterruptedException e) {
log("슬립 중 인터럽트 되었습니다. 종료...");
Thread.currentThread().interrupt(); // 현재 스레드의 인터럽트 상태를 복원
break;
}
}
return "Completed";
}
추가적으로 참고할 수 있는 링크
위 링크에서는 스레드가 어떻게 인터럽트에 반응하는지에 대한 논의가 이뤄졌습니다. 스레드의 인터럽트 처리와 작업의 중단 방식에 대한 자세한 내용을 파악하는 데 도움이 될 것입니다.
위에서 설명드린 방법들이 실질적인 문제 해결에 기여했으면 좋겠습니다. 질문자님의 상황에 맞는 효율적인 설계를 통해 문제를 해결하시기 바랍니다.
저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.
모니터와 synchronized, ReentrantLock, 원자적연산 CAS관련해서 추가적으로 더 깊게 공부했는데 제가 이해한 것이 맞나요??
0
85
1
2.스레드 생성과 실행 - 17P 그림 문의
0
74
2
자바 동시성 현업에서 사용예시가 궁금합니다
0
136
1
ReentrantLock 동작 원리에 대한 질문입니다.
0
83
1
synchronized 대신 join 을 사용하여 순서를 보장할 경우 해법이 아닌가요?
0
94
2
메모리 가시성 문제 질문
0
72
1
Future4-이유 질문
0
64
1
오타 제보
0
76
2
runnable 질문
0
95
2
자바가 아닌 다른 언어에서도
0
112
1
메모리 가시성 문제가 발생하는 이유
0
125
1
데몬스레드가 어떨 때 사용이 되는지 궁금합니다.
0
78
1
Future.cancel() 취소를 사용하는 예가 궁금합니다.
0
84
1
synchronized 와 인스턴스의 lock
0
91
2
synchronized 키워드만으로 메모리 가시성이 해결되는 이유가 궁급합니다.
0
63
1
[스레드 풀과 Executor 프레임워크1][문제와 풀이] `log("일부 작업이 실패했습니다.");` 실행되는 경우가 있을까요?
0
59
1
원자적 연산이 멀티스레드 상황에서 안전한 이유를 제대로 이해했는지 확인 부탁드립니다
0
67
2
자바 고급 1,2,3편 같이 진행해도 문제없나요
0
77
2
CPU 캐시 때문에도 잔액이 200원이 될 수 있나요?
0
105
2
synchronized 메서드와 join 관련 질문이 있습니다.
0
69
2
섹션 14. 115번 강의 내용 질문
0
83
2
교안에 있는 7페이지 데이터 영역
0
51
1
Executor 스레드 풀 관리 질문
0
108
2
문제와 풀이 질문!
0
78
1