我有来自不同来源(多播、tcp)的不同数据。我打算使用不同的Disruptor来单独管理每种类型的数据，而我希望通过一个线程使用所有这些数据。
这样的模型Disruptor是为什么而设计的？我们如何将同一线程共享给多个disruptor？
浏览 8提问于2018-03-27得票数 0
我对的理解是，它是一个充满可怕的、快速的、可怕的并发Java代码的罐子，它允许每秒2,000万条消息的吞吐量(如果使用正确的话)。
而且，如果我完全偏离了所有这些，并且似乎完全误解了LMAX的使用，那么有人能提供一个具
浏览 1提问于2013-03-29得票数 2
1回答
我也在考虑在我们的应用程序中集成破坏模式。在我开始使用干扰器之前，我对一些事情有些不确定
I有3个生成器，主要是一个非序列化请求的修复线程。另一条随着市场的移动而不断调整订单价格的线程。此外，我们还有一个线程，负责反序列化从GUI应用程序发送的请求。目前，所有三个线程都写入阻塞队列(因此，我们在队列上看到了很多争用)，(干扰者)讨论了单个编写器的原理，从我所读到的情况来看，这种方法的规模是最好的。是否可以让上述三个线程在典型的请求/响应应用程序中服从单个编写器principle?Also，特别是在我们的情况下，我们在内存缓存上有争用，因为当我们用响应更新缓存时，需要锁定缓存，而请求可能发生在相
浏览 2提问于2012-02-22得票数 3
回答已采纳
LMAX的Disruptor模式有开源的和版本，如视频中所描述的。这是。更新
很明显是的分解模式。
浏览 6提问于2011-08-04得票数 15
回答已采纳
我最近被介绍给LMAX Disruptor，并决定试一试。多亏了开发人员，安装过程迅速而轻松。但我想如果有人能帮我的话，我会遇到麻烦。public class Consumer { private final Disruptor<Event>disruptor; private final SequenceBarrier
浏览 2提问于2018-05-27得票数 0
2回答
我正在尝试学习如何使用Disruptor.NET消息传递框架，但我找不到任何实际的示例。有相当多的文章是关于它是如何工作的，但我找不到任何实际去向你展示如何实现这些方法的文章。举个例子吧？
浏览 0提问于2012-01-14得票数 25
回答已采纳
例如，在这样的工作池中工作的两组处理程序(我猜)：handleEventsWithWorkerPool(.thenHandleEventsWithWorkerPool;import com.lmax.disruptor.WorkHandler;
import com.lmax.disruptor.dsl.DisruptoreventC
浏览 2提问于2013-07-29得票数 0
回答已采纳
1回答
我尝试了重写disruptor中的start方法，但这段代码仍然在执行线程上运行，而不是在disruptor线程上运行，如下所示：Disruptor<OrderBasedEventHolder> disruptor = new Disruptor<>(new Disru
浏览 14提问于2021-03-16得票数 0
我发现github中的Lmax Disruptor的用户指南非常简单，现在我有一个生产者和五个消费者的问题，之后我需要总结消费者的结果，有任何演示，如何找到Lmax Disruptor钻石(一个生产者5
浏览 14提问于2015-02-03得票数 1
1回答
遵循关于Java中Disruptor的教程，然后进行以下调用val disruptor = Disruptor<LongEvent>(LongEvent::new, bufferSize, executor)
浏览 2提问于2017-06-30得票数 0
所以我决定在我的程序中使用Disruptor，但是当我实现它时，我发现现在Disruptor花在50微秒上，而BlockingCollection仍然花费在14-18微秒上。然后Disruptor花费30-50微秒来传送。第二个选项是模拟活动。然后，Disruptor花费7微秒来交付。= new Disruptor.Dsl.Disruptor<ValueEntry>(() => new ValueEntry(), RingSize, TaskScheduler.Defa
浏览 7提问于2012-11-15得票数 0
例如，在Java中，我可以使用LMAX中断器实现这一点：在Kotlin中，我尝试了以下类似的方法：
val disruptor = Disruptor<NetworkEvent
浏览 6提问于2015-10-22得票数 2
回答已采纳
2回答
我知道我的问题违背了Disruptor API的基本主张。但随着我对它的了解，我写了一个程序来替换我使用ArrayLinkedBlockingQueue的1P-1C用例。但是当我运行这个程序时，我发现使用disruptor的总时间比ArrayLinkedBlockingQueue还要长。我一定是做错了什么或测量错了，但我不确定我的程序中是什么。有谁有意见吗？;import com.lmax.disruptor.EventHandler;
im
浏览 4提问于2014-01-26得票数 0
1回答
一切都很好，直到上个星期，我们看到了来自Disruptor的信息。我们的Disruptor结构非常简单：每个Eventhandler所以我的问题是：
如果是，在什么条件下它可以丢弃消息？
浏览 7提问于2017-03-16得票数 3
请帮帮忙
TRACE AsyncLoggerConfigHelper creating new disruptor. Ref count is 1.TRACE AsyncLoggerConfigHelper not starting new disruptor, using existing object. Ref count is 2.TRACE AsyncLoggerConfigHelper not starting new disruptor, using existing object. Ref count is 3.TRACE A
浏览 12提问于2014-08-25得票数 1
2回答
Executors.newFixedThreadPool(NUM_EVENT_PROCESSORS);
disru
浏览 7提问于2015-07-30得票数 0
回答已采纳
2回答
颠覆者还是JMS？
、、、
颠覆者实际上是应用程序的替代品，而不是JMS吗？我目前使用JMS消息传输任务。目前我使用的是JMS，我有一个生产者向队列发送消息，还有一个消费者(MDB)将消息从队列中拉出。
浏览 1提问于2012-03-14得票数 4
2回答
生产者{import com.lmax.disruptor.BusySpinWaitStrategy;import com.lmax.disru
浏览 9提问于2017-07-03得票数 3
回答已采纳
2回答
Medium 50 m3Warp DisruptorMedium 5 m3Tracking DisruptorI 1 Tracking Disruptor Small Medium 5 m3
转换为array，如下所示
浏览 0提问于2013-02-03得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
