isInterrupted 질문 있다.

Question

지금 우리가 taskExecutor를 비동기로 설정했다는 가정이라 else 문만 보고 있는게 맞나? syncTaskExecutor 라면, if 문에도 걸릴거같은데 말이다. // ThreadStepInterruptionPolicy.isInterrupted private boolean isInterrupted(StepExecution stepExecution) { boolean interrupted = Thread.currentThread().isInterrupted(); if (interrupted) { ... } else { interrupted = stepExecution.isTerminateOnly(); <-- (2) 이 녀석에서 true를 반환하고 } return interrupted; }

communityai8509 · Answer

안녕하세요, 인프런 AI 인턴입니다. 비오님, taskExecutor 가 비동기인지 동기인지에 따라 else 문만 확인하는 것은 아닙니다. isInterrupted() 는 다음 순서로 항상 두 가지 상태를 확인합니다. private boolean isInterrupted(StepExecution stepExecution) { boolean interrupted = Thread.currentThread().isInterrupted(); if (interrupted) { // 현재 실행 중인 스레드가 interrupt 상태 } else { interrupted = stepExecution.isTerminateOnly(); } return interrupted; } 먼저 현재 스레드의 인터럽트 상태를 확인합니다. Thread.currentThread().isInterrupted() 현재 스레드가 인터럽트된 상태라면 true 가 되므로 if 블록으로 들어갑니다. 반대로 현재 스레드가 인터럽트되지 않았다면 false 가 되므로 else 블록에서 다음을 확인합니다. stepExecution.isTerminateOnly() 따라서 else 블록은 비동기 실행일 때만 확인하는 것이 아니라, 현재 스레드가 인터럽트되지 않은 모든 경우에 확인됩니다. SyncTaskExecutor 를 사용하는 경우에는 작업이 호출한 스레드에서 동기적으로 실행됩니다. SyncTaskExecutor 이때도 해당 스레드의 인터럽트 상태가 true 라면 if 블록으로 들어가고, 그렇지 않다면 else 블록에서 terminateOnly 를 확인합니다. 비동기 실행에서도 마찬가지입니다. taskExecutor.execute(...) 다만 비동기 실행에서는 작업을 실제로 수행하는 별도의 워커 스레드에서 다음 코드가 실행됩니다. 즉, 중요한 차이는 if 와 else 중 어느 쪽만 실행되는 것이 아니라, 어떤 스레드에서 Thread.currentThread().isInterrupted() 를 확인하느냐입니다. 정리하면 다음과 같습니다. 현재 실행 스레드가 interrupt 상태다 → if 블록 실행 → true 반환 현재 실행 스레드가 interrupt 상태가 아니다 → else 블록 실행 → stepExecution.isTerminateOnly() 확인 따라서 SyncTaskExecutor 라면 말씀하신 것처럼 호출 스레드가 인터럽트된 경우 if 블록에도 들어갈 수 있습니다. 또한 Thread.currentThread().isInterrupted() 는 인터럽트 상태를 초기화하지 않고 확인만 하므로, 이후에도 해당 스레드의 인터럽트 상태가 유지될 수 있습니다. 참고로 Spring Batch가 Spring Boot 애플리케이션에서 동작하는 방식은 다음 공식 문서에서도 확인할 수 있습니다. https://docs.spring.io/spring-boot/docs/current/reference/htmlsingle/#howto.batch