lmax

0热度

1回答

我在我的Web应用程序中使用了LMAX干扰程序，它接受http请求参数并将它们处理到环缓冲区。 3个事件处理程序处理和处理数据，最后一个将其保存到数据库中。当实例化servlet时，初始化一次环形缓冲区。这是正确的吗？ public void init() throws ServletException { Disruptor<CampaignCode> disruptor = ne

1热度

2回答

为什么使用较小的环形缓冲区会干扰较慢？

继Disruptor Getting Started Guide之后，我已经与一个生产者和一个消费者建立了一个最小的破坏者。生产者 import com.lmax.disruptor.RingBuffer; public class LongEventProducer { private final RingBuffer<LongEvent> ringBuffer;

4热度

2回答

用单线程写LMAX

我已经介绍了LMAX和这个美妙的概念，叫做RingBuffer。所以，人们告诉说，当只写一个线程的性能比使用多线程写入环缓冲更好... 但是我真的不觉得可能只有一个应用程序只使用一个线程写入环形缓冲区。我真的不明白lmax如何做（如果他们这样做）。例如，N个不同的交易者在交易中下达订单，那些都是异步请求，这些请求被转换为订单并放入循环缓冲区，他们如何可能使用一个线程编写这些请求？问题1.我可能

2热度

1回答

在干扰程序中使用TimeoutBlockingWaitStrategy时出现空指针异常

我正在使用workerpool示例，并尝试使用不同的WaitStrategies。当我尝试TimeoutBlockingWaitStrategy时，出现错误。这是程序和调用堆栈。 package org.lmax.experiment.test; import java.util.Random; import java.util.concurrent.ExecutionException;

0热度

1回答

LMAX的破产者以何种方式可用于股票市场？

我已经做了一些研究与扰乱模式，有一件事我不能包裹我的头周围。有生产者，提供环缓冲区的条目。有一个环缓冲区，基本上是一个固定的，但无尽的阵列。有消费者（主要是sperate线程），处理来自环缓冲区的条目。我想涉及如何破坏者百通能够在A股市场的实际情况使用。通常你会有包含所有订单的订单。我如何看待它，制片人会收到经纪人的新订单。生产者将订单放入环缓冲区。订单放入循环缓冲区后，消费者提取订单并

1热度

1回答

关于在Java EE应用程序中使用log4j2 AsynchronousLoggers

我想在Java EE 7应用程序中使用Log4j2异步记录器。这需要在类路径中使用LMAX disruptor-3.0.0.jar或更高版本。我担心这打破了与在Java EE容器内启动“用户”线程相关的规则。 log4j2自动配置是否检测到Jee容器的存在？还是我需要传递log4j2 ManagedExecutorService？在WorkerPool中使用？

0热度

1回答

我没有看到Disruptor的性能提升

我知道我的问题违背了Disruptor API的基本声明。但是当我正在学习它时，我写了一个程序来替换我使用ArrayLinkedBlockingQueue的我的1P-1C用例。但是，当我运行这个程序时，我总是花费更多的时间来处理干扰，而不是ArrayLinkedBlockingQueue。我一定是做错了什么或者错了，但我不确定我的计划是什么。有人有意见吗？（这是一个测试程序，所以很明显我的事件处

0热度

1回答

应用程序中干扰程序的最大数量

使用LMAX干扰程序，我们观察到，如果我们在应用程序中一起使用5-10个干扰程序（有点像干扰链，每个干扰程序有一个消费者执行指定的任务然后将消息交给下一个干扰程序/环缓冲区），CPU使用率达到90％以上，系统变得无响应，直到我们关闭应用程序，我们觉得这是因为有太多活动的干扰程序线程。即使干扰者没有真正处理任何事情，也会发生这种情况。任何人都可以评论什么应该是应用程序中使用的最佳干扰程序数量？

0热度

1回答

（LMAX disruptor）如何通过我自己而不是通过回调来获取数据？

我知道LMAX干扰器是一个高性能的线程间消息传递库。但是当我尝试使用它时，我发现eventhandler使用回调方法来处理数据。 void onEvent(T event, long sequence, boolean endOfBatch) throws java.lang.Exception 时，发行商已发行将事件RingBuffer 调用，但如果我不

2热度

2回答

Lmax Disruptor，许多消费者 - 如何让消费者只接受特定类型的消息并独立进行？

我计划在我的干扰者中拥有许多平行消费者。我需要每个消费者只消费对他们有意义的消息。例如，我有类型A，B，C的消息和我已缓冲像 #1 - type A, #2 - type B, #3 - type C, #4 - type A, #5 - type C, #6 - type C, (and so on) 我有消费者对于每种类型的。我怎样才能达到这个消费者，因为A会采取消息1和4，对于B型