Disruptor helloworld örneği

Question

Disruptor framework'u öğrenmek istiyorum. Java program dili ile ana yöntemde çalışabilen bir helloworld örneğini kim verebilir?

Answer 1

Burada, Disruptor kitaplığının nasıl kullanılacağı ile ilgili basit, çalıştırılabilir bir örnek. Örnek, Disruptor kütüphanesinin 2.10.4 versiyonunu kullanarak yazılmıştır. Ben de bu konuya yayınlanan çapraz ettik

https://github.com/trevorbernard/disruptor-examples

: benim tarafımdan The simplest and actual example code of LMAX Disruptor İşte

Answer 2

tane daha. Açık kaynaklı Lmax kitaplıklarını kullanarak bir devre kesici örneği denedim.
Lmax bozucusunun (bozulmanın içsel değil) kullanımının arkasındaki fikir, mesaj dağıtıcı oluşturmak ve tüketici gibi olay dinleyicisini kaydetmek olduğunu düşünüyorum.

İleti türünü belirterek bir Bozucu Oluşturursunuz.

Disruptor<Message> disruptor = new Disruptor<Message>(Message.EVENT_FACTORY, 2048, exec);` 

Sen bölücü ve üreticiye iade Ringbuffer geçmesini bozucu

  disruptor.handleEventsWith(handler); 

Başlangıç ​​ile

final EventHandler<Message> handler = new EventHandler<Message>() { 
     // event will eventually be recycled by the Disruptor after it wraps 
     public void onEvent(final Message event, final long sequence, final boolean endOfBatch) throws Exception { 
      Integer value = event.getMsg(); 
      if(value % 10000 == 0){ 
       System.out.println("ValueEvent: " + value + " Sequence: " + sequence); 
       double timeINnanos = (System.nanoTime()-startTime); 
       double timetaken = (timeINnanos/1e9); 
       System.out.println("Time Taken till now in sec " + timetaken); 
      } 
     } 
    }; 

Kayıt işleyicisi bir işleyicisi oluştur

  RingBuffer<Message> ringBuffer = disruptor.start(); 
     Producer producer = new Producer(ringBuffer); 

Tam kod burada Github link

Answer 3

bulunabilir Ben LMAX kodu LMAX Source Code Test Directory test dizinine bir göz atmanızı öneririm. Bence LMAX ile yapabileceğiniz her türlü şey için en iyi kaynak. Basit Örneğin, ben de size DSL examples.