0
Disruptor 또는 publish()을 사용하는 것이 다른 이유로 또는 허용되는 시간에 호출되지 않을 때 예외가 throw되면 어떻게됩니까? next()과 publish() 사이에 예외가 발생하면 어떻게됩니까?Disruptor에서 next()와 publish() 사이에 예외가 발생하면 어떻게됩니까?
이러한 경우를 처리하기위한 복구/시간 초과 기술은 무엇입니까?
A
답변
2
Disruptor 내에서 게시하려면 자체 호출이 항상 호출되도록 finally 블록에 있습니다. 예 : Disruptor.java#1017-1027
게시는 이벤트 처리기에서 사용할 수있는 슬롯을 표시하므로 게시 호출이 발생할 때까지 작동을 멈 춥니 다.
회복 전략은 깨뜨리지 않습니다;) 즉, 사용 준비가 끝나고 항상 게시를 호출 할 때까지 슬롯을 차지할 필요가 없습니다. 슬롯을 요청한 데이터를 게시하고 싶지 않으면 슬롯에 들어가기 위해 일종의 오류 마커가 필요할 수 있습니다.