Voglio imparare lo Disruptor framework. Chi può darmi un esempio di helloworld che può essere eseguito nel metodo principale con il linguaggio del programma Java?Disruptor helloworld esempio
risposta
Ecco un esempio semplice e eseguibile di come utilizzare la libreria Disruptor. L'esempio è scritto usando la versione 2.10.4 della libreria Disruptor.
https://github.com/trevorbernard/disruptor-examples
ho anche incrociato postato su questo thread: The simplest and actual example code of LMAX Disruptor
qui ancora una da parte mia. Ho provato un esempio di disgregatore usando le librerie Lmax open source.
Penso che l'idea dietro l'uso di lmax disgregatore (non l'interno del disruptor) sia quella di creare un dispatcher di messaggi e registrare un listener di eventi come il consumatore.
Si crea un Disruptor, con la specifica del tipo di messaggio.
Disruptor<Message> disruptor = new Disruptor<Message>(Message.EVENT_FACTORY, 2048, exec);`
si crea un gestore
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);
}
}
};
gestore Registrati con disgregatore
disruptor.handleEventsWith(handler);
di inizio che disgregatore e passare il ringbuffer restituita al produttore
RingBuffer<Message> ringBuffer = disruptor.start();
Producer producer = new Producer(ringBuffer);
codice completo può essere trovato qui Github link
io ti suggerirei di dare un'occhiata alla directory test nel codice LMAX LMAX Source Code Test Directory. Secondo me è la migliore fonte per tutti i tipi di cose che puoi fare con LMAX. Per l'esempio semplice, si prega di dare un'occhiata al seguente link Simple Example
Vorrei anche suggerire di prendere uno sguardo al DSL examples.
- 1. attivo MQ - esempio eccezione HelloWorld
- 2. Ottenere codiceIgniter Esempio HelloWorld per lavoro
- 3. Come creare un esempio di HelloWorld JAX-WS (client - servizio)?
- 4. server web mongoose programma helloworld
- 5. Eclipse - HelloWorld - Errore Android?
- 6. Il codice di esempio più semplice ed attuale di LMAX Disruptor
- 7. JBoss HelloWorld appilcation non inizia
- 8. ScalaFX: errore di compilazione HelloWorld
- 9. Croce Compile helloworld per ARM
- 10. R da C - Helloworld più semplice
- 11. Perché "git push helloworld + master: master" invece di "git push helloworld"?
- 12. JavaFX e compilazione di HelloWorld con Ant
- 13. PyInstaller non funziona su un semplice programma HelloWorld
- 14. Come compilare Helloworld con il codice sorgente Android
- 15. Primavera errore esempio ciao mondo
- 16. Hadoop Hello World Esempio e introduzione
- 17. Esempio di threading semplice esempio
- 18. Si dovrebbe usare Disruptor (LMAX) con un grande modello in memoria e CQRS?
- 19. C'è qualche motivo per usare Netty con Disruptor in termini di prestazioni?
- 20. Esempio Python dell'Enlang websocket di Joe esempio
- 21. Esempio MVVM/Esempio di implementazione in iOS
- 22. Esempio di un esempio di bridge
- 23. Problemi con esempio ciao mondo di cherrypy esecuzione
- 24. compressibilità Esempio
- 25. notifyDataSetChanged esempio
- 26. NSXMLParser esempio
- 27. pyparsing esempio
- 28. Esempio TTPickerTextField
- 29. esempio WeakHashMap
- 30. Esempio compilatori
Sede [Il codice di esempio più semplice e reale di LMAX Disruptor] [1]. [1]: http://stackoverflow.com/questions/9168602/the-simplest-and-actual-example-code-of-lmax-disruptor – Heri