[비동기][Spring] @Async 어노테이션 커스텀2 - RejectedExecutorException 핸들링

이전에는 아래와 같이 서비스 단에서 비동기 메소드를 호출할 때 try/catch 문을 사용하여 RejectedExecutorException에 대한 방어로직을 추가하였다.

 

 

이러한 사실을 알게되고 회사에 공유하였는데 신기한 사실을 알게되었다.

try/catch문으로 방어로직을 추가해주지 않아도 AsyncConfig에서 RejectedExecutorException에 대한 대응 처리를 설정할 수 있다는 것이다.

 

바로 이렇게 말이다 ..

setRejectedExecutionHandler : RejectedExecution 예외가 발생했을 때 어떻게 처리할지에 대한 옵션이다.

new ThreadPoolExecutor에서 호출하는 메소드는 4가지가 있다.

- AbortPolicy : 디폴트값. RejectedExecutionException을 발생시킨다.

- DiscardOldestPolicy : 오래된 작업을 무시한다.

- DiscardPolicy : 처리하려는 작업을 무시한다.

- CallerRunsPolicy : shutdown 상태가 아닐 때, ThreadPoolTaskExecutor에 요청한 thread에서 다른 thread에 위임하지 않고 직접 처리한다.

즉, 요청한 쓰레드가 메인쓰레드였다면 다른 쓰레드에 위임하지 않고 메인쓰레드가 직접 처리한다는 것이다.

=> 쓰레드풀이 다 찼을 때 요청한 쓰레드에서 동기로 처리한다는 것이다.

 

 

실험

쓰레드풀이 다 찼을 때 정말 RejectedExecutorException이 발생할 상황에서 exception이 발생하지 않고 동기로 요청을 처리하는지 실험을 진행해보았다.

 

1️⃣ 아무런 조치를 하지 않았을 때 (AbortPolicy())

결과

RejectedExecutorException이 발생하였음. (try/catch 문으로 방어로직 추가한 상태)

 

 

2️⃣ executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); 사용했을 때

결과

RejectedExecutorException이 발생하지 않고 요청이 처리 완료됨. (요청한 쓰레드에서 동기로 처리되었음)