Dayoung

Be-Developer

WebFlux Thread DeadLock

Dec 30, 2020

SpringBoot
rxJava

WebFlux Thread lock

사용중인 코드

Webclient()
...
.retrieve()
.bodyToMono(SomeClass.class)
.block()

쓰레드 덤프

"http-nio-8000-exec-16" Id=0x54 WAITING on java.util.concurrent.CountDownLatch$Sync@4e78b2fd
    at sun.misc.Unsafe.park(Native Method)
    -  waiting on java.util.concurrent.CountDownLatch$Sync@4e78b2fd
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
    at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
    at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:81)
    at reactor.core.publisher.Mono.block(Mono.java:1183)

해결 방안

DNS 캐싱관련 발생 이슈로, netty의 async DNSResolver을 사용하면 해결가능하다.

AsyncDNSResolver는 netty 4.1.56 부터 제공된다.

Netty DNS를 디폴트로 사용하는 reactor-netty 1.0 버전을 사용하면 추가 설정없이 해결 가능하다.

참고

Deadlock이 발생할수있는 상황 및 Nonblocking thread에서 block이 일어났을때 감지 및 방지해줄수있는 BlockHound

Reactor Debugging Experience