disruptor-pattern

1열

1답변

어떻게 타임 아웃 기능을 LMAX Disruptor Queue에 적용 할 수 있습니까? LMAX 스럽 터의 개발자/사용자 <a href="http://code.google.com/p/disruptor/" rel="nofollow">http://code.google.com/p/disruptor/</a>으로

: 내 질문 : 사람이 스럽 예에 타임 아웃 기능을 어떻게 적용되는지에 대한 접근 방식을 제안 할 수 EventHandler를 사용하고 있습니까? - ACK 메시지 서버 ACK 처리기에서 수신 - 받은 편지함은 네트워크를 통해 서버로 전송 된 메시지 - 보낼 편지함 : 여기에 작품의 내 라인에서 온 한 시나리오 NACKed로 표시 메시지를 보낼 편지함 (많

23열

2답변

Disruptor.NET 예제

Disruptor.NET 메시징 프레임 워크를 사용하는 방법을 배우려고하는데 실용적인 예제를 찾을 수 없습니다. 어떻게 작동하는지에 대한 사진이있는 꽤 많은 기사가 있지만 실제로 갈 곳을 찾지 못하고 메서드를 구현하는 방법을 보여줍니다. 예를 들면?

2열

2답변

Disruptor Next/Publish 메소드에 대한 액세스를 동기화해야합니까?

아래 코드는 방해 요소가있는 사람들에게 충분하기 때문에 전체 목록을 제공하지 않습니다. Next 및 Publish 메서드를 호출하면 스레드로부터 안전할까요? 아래의 예들 사이에 올바른 것이 무엇일까? Attach은 다른 스레드에서 동시에 호출 할 수 있습니다. 그리고 나는 여러 소비자가있다. 실시 예 1. 모든 것을 잠그십시오 : private object

2열

1답변

이 Java 응용 프로그램은 스레드를 확장하거나 실행 가능을 구현하지 않고 여러 스레드를 어떻게 실행합니까?

저는 Java를 배우고 있으며 기존 응용 프로그램에서 runnable을 사용하여 멀티 스레딩을 할 수있었습니다. 나는 현재 스레드 (thread간에 변수를 공유하기 위해)를 혼란시키는 사람을보고 있었지만, 저자가 실제로 스레드를 생성하는 방법을 알 수는 없다. 나는 그가 내 프로그램에서 실행 가능한 클래스를 제출하는 데 사용하는 Executor를 사용하고

4열

2답변

Disruptor 또는 JMS?

실제로 JMS 대신 애플리케이션을 대체 할 수 있습니까? 현재 JMS 메시지를 사용하여 작업을 전송하고 있습니다. Disruptor가 메시지 전송을 위해 교체 할 예정입니까? 각각의 장단점은 무엇입니까? 현재 JMS를 사용하고 있으며 메시지를 대기열로 보내고 대기열에서 메시지를 보내는 소비자 (MDB)가 있습니다. 감사합니다.

3열

2답변

Java의 LockSupport.parkNanos()와 동일한 Windows C++

Win7 x64에서는이 기능과 동일한 기능을 구현해야합니다. 처음에는 SwitchToThread()을 사용했지만 극한 상황에서 교착 상태가 발생하기 때문에이 방법은 작동하지 않습니다. 내가 찾을 수있는 유일한 대안은 Sleep()입니다. 아직 밀리 초 해상도에서만 작동하므로 성능 희생자가 될 가능성이 높습니다. 그래도 여전히 LockSupport.parkN

1열

1답변

Disruptor의 ClaimStrategy 버퍼 크기를 설정하는 방법

이제는 disruptor를 사용하고 있는데, consumer-productor의 간단한 예제를 얻습니다. 완벽하게 실행되지만, 어떤 크기로 설정해야하는지 알지 못합니다. 개인 정적 final int BUFFER_SIZE = 4; private final RingBuffer<StockEvent> ringBuffer = new RingBuffer<St

2열

1답변

Java : Disruptor 또는 Not를 사용하십시오. .

Hy, 현재 amq 대기열에서 2 개의 값을 가져 와서 일련의 수학적 계산을 수행하는 프로그램을 개발 중입니다. 내 프로그램이 콜백 (청취자)을 통해 메시지를 수신하고 수신하는 amq 서버에 주제가 작성되었습니다. 이제 메시지가 도착할 때마다 두 값이 SynchronizedDescriptiveStatistics 개체에서 가져와 추가됩니다. 값 목록에 추가

0열

2답변

LMAX의 Disruptor는 공유 변수가있는 다중 생성자와 어떻게 작동합니까?

Disruptor를 처음 사용했습니다. 다음과 같은 두 가지 쿼리가 있습니다. Q1. one producer to one consumer 및 one producer to multiple dependent consumers의 샘플 코드를 얻었습니다. 여러 소비자의 샘플 코드를 여러 소비자 또는 Sequencer : 3P - 1C에서 얻고 싶습니다. 어떤 블로

4열

1답변

LMAX Disruptor를 C#으로 포팅 할 수 있습니까?

일부 사람들이 C++ 포트에서 작업하고 있음을 알고 있습니다. C# 포트가 가능합니까? 특히 나는 휘발성 필드 주위의 제한이 C#에서 단지 32 비트라고 생각하고 있습니다. 그게 유일한 문제라면 32 비트로 허용되는 슬롯 수만있는 링 버퍼를 작성하는 것이 가치 있다고 생각합니까? 이것은 시스템 수명 기간 동안 훨씬 더 적은 이벤트입니다. 이 권리가 있습니까