Java : 과도하게 호출되는 메소드의 디자인 패턴

Question

메소드를 비 차단으로 유지하면서 메소드가 과도하게 호출되지 않도록 Java에서 가장 좋은 방법은 무엇입니까?

내 usecase는 오디오 데이터 용 사용자 지정 버퍼입니다. 데이터를 폴링 할 수있는 버퍼의 메소드는 비 블로킹 (non-blocking)이어야하며, 데이터가 사용 가능하지 않을 때 메소드가 null을 리턴하는 것이 허용 가능합니다. 메서드가 블로킹되는 것은 용납되지 않으므로 동기화하는 것을 원하지 않습니다. 메서드를 지나치게 호출하면 음질이 떨어집니다. 그렇다면 호출자가 스스로 행동하지 않고도 과부하로 메소드를 보호하려면 어떻게해야합니까?

Answer 1

당신이 "java design pattern"을 물었 기 때문에 스레드 폴링 폴링이 다소 안티 패턴이라고 말할 수 있습니다. 일반적으로는 아니지만 실제로는 톤이 아닙니다.

나는 그것을 보았을 때 거의 항상 호출자가 자신의 통화 속도를 제한했다. 발신자가 음질을 좋게 유지하는 데 관심을 갖고 있으며 CPU를 위험에 빠뜨리고 싶지는 않습니다. 방법을 문서화하고 발신자에게 맡길 수 있습니까?

그러나 귀하의 질문에 답하기 위해 저는 책임을 뒤집을 것이고 소비자가 귀하의 버퍼에 의해 일정 (3ms ??)을 먹는 콜백을 등록하게 할 것입니다. 따라서 소비자가 당기지 않고 생산자가 푸시합니다.

초기 "반응성 스트림"사양 (http://www.reactive-streams.org/)은이를 구현하고 소비자가 처리 할 수있는 항목 수를 생산자에게 요청해야하며 생산자가 사용 가능할 때 피드를 제공해야합니다.

https://github.com/reactive-streams/reactive-streams/blob/master/api/src/main/java/org/reactivestreams/Subscription.java

이 직접 적용되지이다하더라도, 그것은 당신에게 몇 가지 아이디어를 줄 수도 있습니다.

행운을 비네.

Answer 2

는 자바 NIO 프레임 워크를 사용할 수 있습니다 ...

내 현재의 접근 방식은 마지막 여론 조사의 타임 스탬프를 기억하고 짧은은 3ms의보다 전에의 경우는 null를 반환하는 것입니다, 그러나 이것은 "해키"조금 느낌 이리?

조금 더 많은 정보가 도움이 될 것입니다. 데이터에 관심이있는 사람이 어디에서 왔는지 ...

즉 네트워크에서 데이터가 도착하면 버퍼에 데이터를 채울 수 있습니다 (일부 종류의 LRU 맵과 부품에 대한 시간 정보 포함) 데이터를 필요로하는 작업은 버퍼를 읽을 수 있습니까?

Answer 3

ConcurrentLinkedQueue이 바로 그 것입니다. 비 블로킹이며 사용할 수있는 메시지가 없으면 null을 반환합니다. 어느 쪽이든 ConcurrentLinkedDequeue