disruptor-pattern Questions
1
Solved
I tried to implement Lmax in python .I tried to handle data in 4 processes
import disruptor
import multiprocessing
import random
if __name__ == '__main__':
cb = disruptor.CircularBuffer(5)
de...
Holmen asked 11/10, 2021 at 5:37
0
I am trying to implement disruptor in Lmax architecture .
As you know in lmax architecture we have a ring buffer for creating a queue to process data .
Here you can see the structure of that :
I h...
Jacal asked 4/10, 2021 at 9:53
3
Solved
My system has two different types of messages - type A and B. Each message has a different structure - type A contains an int member and type B contains a double member. My system needs to pass bot...
Hitherto asked 30/5, 2013 at 21:12
2
I've taken the code example from Stack Overflow question Disruptor.NET example and modified it to "measure" time. Full listing is below:
using System;
using System.Diagnostics;
using System.Linq;
...
Tiercel asked 11/11, 2012 at 19:49
3
Solved
While using the disruptor, there may be a consumer(s) that is lagging behind, and because of that slow consumer, the whole application is affected.
Keeping in mind that every producer(Publisher) ...
Bremser asked 23/7, 2012 at 3:25
3
Solved
As the RingBuffer up-front allocates objects of a given type, how can you use a single ring buffer to process messages of various different types?
You can't create new object instances to in...
Contrapuntist asked 3/8, 2011 at 21:12
3
Solved
There are open source Java and .NET versions of LMAX's Disruptor pattern, as described in the video LMAX - How to Do 100K TPS at Less than 1ms Latency. Here is more links to information on th...
Buiron asked 4/8, 2011 at 14:49
3
Solved
I want to learn the Disruptor framework. Who can give me a helloworld example which can run in the main method with Java program language?
Hogg asked 22/3, 2012 at 16:28
1
Solved
I have been recently learning about the LMAX Disruptor and been doing some experimentation. One thing that is puzzling me is the endOfBatch parameter of the onEvent handler method of the EventHandl...
Torsi asked 15/11, 2015 at 5:41
1
Solved
I am investigating LMAX Disruptor's source code, and I came into RingBuffer abstract class. Why are there exactly 7 long fields (p1 ... p7) in RingBufferPad ?
Here is actual code :
https://github...
Wiley asked 12/8, 2015 at 13:34
2
Solved
I'm using the Disruptor framework for performing fast Reed-Solomon error correction on some data. This is my setup:
RS Decoder 1
/ \
Producer- ... - Consumer
\ /
RS Decoder 8
The producer ...
Kuhlman asked 20/2, 2015 at 13:53
5
Solved
I am trying to understand the disruptor pattern. I have watched the InfoQ video and tried to read their paper. I understand there is a ring buffer involved, that it is initialized as an extremely l...
Salamis asked 2/7, 2011 at 20:0
1
Solved
LMAX Disruptor is generally implemented using the following approach:
As in this example, Replicator is responsible for replicating the input events\commands to the slave nodes. Replicating acros...
Hintz asked 8/5, 2014 at 7:46
1
Solved
I am building a simple reactive server which should consume incoming protobuf/protostuff messages from multiple clients, execute some business logic on them and possibly send fire-and-forget messag...
Patsy asked 10/4, 2014 at 6:33
5
Solved
I wish I can get the simplest possible example code, which will show how to use LMAX disruptor(http://code.google.com/p/disruptor/).
Unfortunately every piece of code is out of date. Does someone...
Ollayos asked 6/2, 2012 at 22:56
3
Solved
I'm playing around with the Disruptor framework, and am finding that my event handlers are not being invoked.
Here's my setup code:
private static final int BUFFER_SIZE = 1024 * 8;
private final ...
Crake asked 29/11, 2011 at 11:10
2
Solved
In the LMAX Disruptor pattern, the replicator is used to replicate the input events from a master node to slave node. So the setup would probably look like the following:
The replicator of maste...
Literary asked 17/7, 2013 at 10:41
1
Solved
Is there some example code for migrating from the standard LinkedBlockingQueue to LMAX' Disruptor architecture? I have an event handling application (single producer, multiple consumers) that might...
Needful asked 1/6, 2013 at 15:56
1
Solved
Is the following correct?
The disruptor pattern has better parallel performance and scalability if each entry has to be processed in multiple ways (io operations or annotations), since that can b...
Cupid asked 11/3, 2013 at 14:28
2
Solved
I am trying to learn how to use the Disruptor.NET messaging framework, and I can't find any practical examples. There are quite a few articles out there with pictures about how it works, but I can'...
Rozanna asked 14/1, 2012 at 6:52
2
Solved
I'm not providing full listing as below code is enough for those who familar with disruptor.
The question is if calling Next and Publish methods is thread-safe. Between examples below what would be...
Engender asked 12/11, 2012 at 19:39
2
Solved
In this example https://mcmap.net/q/428408/-disruptor-net-example and here Why is my disruptor example so slow? (at the end of the question) there is 1 publisher which publish items and 1 consumer....
Carine asked 12/11, 2012 at 5:28
2
Solved
Our system has structured model (about 30 different entities with several kind of relations) entirely kept in memory (about 10 Gb) for performance reasons.
On this model we have to do 3 kind of ope...
Irradiate asked 17/10, 2012 at 8:34
1
Solved
I was curious regarding the most common (or recommended) implementations of disruptor about the journaling step. And the most common questions of mine are:
how it is actually implemented (by exam...
Lunar asked 6/9, 2012 at 7:53
1
Solved
I know some people are working on a C++ port.
Is a C# port possible? In particular I'm thinking about the limitations around volatile fields being only 32-bit in C#. If that's the only problem, d...
Magnus asked 11/11, 2011 at 17:1
1 Next >
© 2022 - 2024 — McMap. All rights reserved.