我正在学习LMAX Disruptor，并遇到了一个问题:当我有一个非常大的环形缓冲区时，比如1024，我的生产者比我的消费者快得多，环形缓冲区将保存大量数据，但在我的应用程序结束之前不会发布事件。这意味着我的应用程序将丢失大量数据(我的应用程序不是守护进程)。
我试着放慢制作人的速度，这是有效的。但我不能在我的应用程序中使用这种方法，它会极大地降低我的应用程序的性能。
val ringBufferSize = 1024
val disruptor = new Disruptor[util.Map[String, Object]](new MessageEventFactory, ringBu
浏览 7提问于2019-04-29得票数 0
我正在构建一个简单的反应性服务器，它应该使用来自多个客户端的传入的protobuf/Protu瘤消息，对它们执行一些业务逻辑，并可能向其他用户发送触发和遗忘消息。我想在Netty中实现传输和解码部分。我的问题是:向Disruptor的环形缓冲区性能发布解码消息是否有意义--或者Disruptor提供的额外性能将被内部Netty调度所否定？我应该为Netty提供两个线程(一个用于“接受”，另一个用于“连接”组)，还是一个更好？也许，我应该在Netty的处理程序中按长度字段拆分消息，并在Disruptor的处理程序中执行解码吗？
浏览 0提问于2014-04-10得票数 6
回答已采纳
1回答
我正在使用LMAX颠覆器，它工作得非常好。
我想在中断器的线程生命周期开始时执行一些核心亲和性代码(需要在中断器处理程序的线程上运行)。
我尝试了重写disruptor中的start方法，但这段代码仍然在执行线程上运行，而不是在disruptor线程上运行，如下所示：
ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("DisruptorThread").build();
Disruptor<OrderBasedEventHolder> disruptor = new Disruptor
浏览 14提问于2021-03-16得票数 0
1回答
遵循关于Java中Disruptor的教程，然后进行以下调用
Disruptor<LongEvent> disruptor = new Disruptor<>(LongEvent::new, bufferSize, executor);
其中，LongEvent是使用无参数的默认构造函数实例化的。new LongEvent()。
Kotlin中的等效行正在向::new抛出一个错误。Kotlin中::new的正确语法是什么？
# THIS IS INVALID
val disruptor = Disruptor<LongEvent>(LongEvent::ne
浏览 2提问于2017-06-30得票数 0
例如，在Java中，我可以使用LMAX中断器实现这一点：
Disruptor<NetworkEvent> disruptor = new Disruptor<>(NetworkEvent::new, 2048, Executors.newSingleThreadedExecutor());
在Kotlin中，我尝试了以下类似的方法：
val disruptor = Disruptor<NetworkEvent>({ NetworkEvent() }, 2048, Executors.newSingleThreadExecutor())
但我受到了这个错误的欢
浏览 6提问于2015-10-22得票数 2
回答已采纳
干扰物应该比BlockingCollection快得多。
在我的上一个问题，，我写了两个测试。Disruptor花费了大约1微秒(或更少)，而BlockingCollection则花费了14微秒。
所以我决定在我的程序中使用Disruptor，但是当我实现它时，我发现现在Disruptor花在50微秒上，而BlockingCollection仍然花费在14-18微秒上。
我已经修改了我的生产代码，使之成为“独立测试”，而Disruptor仍然花费了50微秒。为什么？
下面是一个简化的测试。在这个测试中，我有两个选择。第一个选择是Sleep for 1 ms。然后Disruptor花费30-50
浏览 7提问于2012-11-15得票数 0
2回答
我知道我的问题违背了Disruptor API的基本主张。但随着我对它的了解，我写了一个程序来替换我使用ArrayLinkedBlockingQueue的1P-1C用例。但是当我运行这个程序时，我发现使用disruptor的总时间比ArrayLinkedBlockingQueue还要长。我一定是做错了什么或测量错了，但我不确定我的程序中是什么。有谁有意见吗？
(这是一个测试程序，所以很明显我的EventHandler什么也没做)
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executo
浏览 4提问于2014-01-26得票数 0
LMAX的Disruptor模式有开源的和版本，如视频中所描述的。这是。
是否有人知道到C++的端口，要么已经完成，要么处于测试版？
更新
很明显是的分解模式。
浏览 6提问于2011-08-04得票数 15
回答已采纳
1回答
我在我的web应用程序中使用LMAX中断器，它接受http请求参数并将它们处理到循环缓冲区。3个事件处理程序处理和处理数据，最后一个，将其保存到数据库.当servlet被实例化时，初始化一次循环缓冲区。是这样吗？
public void init() throws ServletException {
Disruptor<CampaignCode> disruptor = new Disruptor<CampaignCode>(
CampaignCode.FACTORY, 1024, Executors.newCachedThreadP
浏览 5提问于2013-08-22得票数 1
回答已采纳
我已经将JVM env变量设置为AsyncLoggerConfig.WaitStrategy=Sleep(even，尽管它是默认的)
但是，在启动服务器时，我在服务器日志中获得null，而BlockingWaitStrategy使用干扰者事件处理程序代替SleepWaitStrategy。
请帮帮忙
TRACE AsyncLoggerConfigHelper creating new disruptor. Ref count is 1.
DEBUG property AsyncLoggerConfig.WaitStrategy=null
DEBUG disruptor event handle
浏览 12提问于2014-08-25得票数 1
2回答
作为PHP的新手，我看过文档之类的东西，无法找到这个问题的答案。
我想接受$_POST输入，如下所示：
Large Automated Structural Restoration 1 Hull Repair Unit Medium 50 m3
Experimental 10MN Microwarpdrive I 5 Propulsion Module Medium 50 m3
Warp Disruptor I 1 Warp Scrambler Medium 5 m3
Upgraded EM Ward Amplifier I
浏览 0提问于2013-02-03得票数 2
回答已采纳
2回答
我使用以下事件处理程序运行一个干扰实例：
int NUM_EVENT_PROCESSORS = 5;
executor = Executors.newFixedThreadPool(NUM_EVENT_PROCESSORS);
EventFactory factory = new EventFactory();
System.out.println("Starting Disruptor");
disruptor = new Disruptor<>(factory, RING_SIZE, executor, ProducerType.SINGLE, new
浏览 7提问于2015-07-30得票数 0
回答已采纳
2回答
遵循，我已经建立了一个最小的破坏与单一生产者和单一消费者。
生产者
import com.lmax.disruptor.RingBuffer;
public class LongEventProducer
{
private final RingBuffer<LongEvent> ringBuffer;
public LongEventProducer(RingBuffer<LongEvent> ringBuffer)
{
this.ringBuffer = ringBuffer;
}
public void
浏览 9提问于2017-07-03得票数 3
回答已采纳
Disruptor 3.3.6 com.lmax.disruptor.WorkProcessor中的Disruptor EventReleaser.release()方法。
我不能理解sequence.set(Long.MAX_VALUE)方法。谁能详细解释一下这种方法的目的是什么？
浏览 1提问于2016-11-24得票数 0
我正在使用workerpool示例，并尝试了不同的WaitStrategies。当我尝试TimeoutBlockingWaitStrategy时，我会出错。这是程序和调用堆栈。
package org.lmax.experiment.test;
import java.util.Random;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.con
浏览 1提问于2016-01-24得票数 2
回答已采纳
4回答
我试图用Disruptor读取文本文件并插入到数据库中。
但是我发现CPU的使用率太高了(根据top命令，是200%)。
我对性能调优和线程转储分析很陌生。我不知道出了什么问题。
因此，我执行top -H并找到两个最高的线程(都是99%)，并找到线程转储：
"main" prio=10 tid=0x00007f54a4006800 nid=0x79ab runnable [0x00007f54a8340000]
java.lang.Thread.State: RUNNABLE
at java.lang.Thread.yield(Native Method)
浏览 5提问于2014-06-04得票数 1
回答已采纳
1回答
我对Disruptor框架有一些问题。
publishEvent方法在ringBuffer中无法工作。
我收到了这条错误信息。
方法publishEvent(EventTranslatorOneArg，ByteBuffer)未定义为RingBuffer类型。
这是我的java类。
import java.nio.ByteBuffer;
import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.EventTranslatorOneArg;
import com.lmax.disruptor.EventTransl
浏览 0提问于2014-04-21得票数 0
回答已采纳
我有一个WSO2 APIManager2.5.0安装，部署在两个节点上，作为活动活动。它还拥有WSO2分析和WSO2标识服务器作为关键管理器。
当每个节点启动时，它会在日志中留下三倍相同的错误：
2018-11-14 07:56:50,989 [-] [DisruptorInboundEventThread-8] ERROR AndesSubscriptionManager Could not add subscription: subscriptionId=3091b9ba-867b-4539-bf25-fee511d1813d,storageQueue=AMQP_Topic_throttl
浏览 0提问于2018-11-14得票数 5
回答已采纳
2回答
在disruptor (版本3.3.2)中，每个事件都是Runnable (因为EventProcessor扩展了runnable)。
我正在编写一个应用程序，每当EventHandler抛出异常时，调用disruptor.start()的类需要捕获该异常并做出反应。
现在，如果EventProcessor是一个可调用的，那就很容易了。
在Disruptor中有没有其他方法来传播异常？
浏览 9提问于2015-10-31得票数 0
Apache Storm和LMAX Disruptor之间的对比差异是什么？两者都在一起解决不同的问题吗？如果有，是什么？我花了几天时间学习Apache Storm，我发现它与LMAX Disruptor有一些相似之处。虽然LMAX Disruptor用于在线程之间传递消息，但对数据执行某些处理的事件被链接在一起(如树、菱形、三角形、简单序列)。同样，风暴的Spouts与多个对数据执行某些处理的Bolts链接在一起，数据从一个螺栓传递到另一个，直到没有更多的螺栓。这是不是类似于LMAX Disruptor，还是我看错了？除此之外，Apache Storm是否也可以像LMAX Disruptor
浏览 3提问于2015-03-19得票数 2
我试着用干扰器来处理信息。我需要两个阶段的处理。例如，在这样的工作池中工作的两组处理程序(我猜)：
disruptor.
handleEventsWithWorkerPool(
firstPhaseHandlers)
.thenHandleEventsWithWorkerPool(
secondPhaseHandlers);
当使用上面的代码时，如果我在每个组中放置一个以上的工作人员，性能就会下降。这意味着大量的CPU浪费在完全相同的工作量上。
我试着调整环形缓冲区的大小(我已经看到这对性能有影响)，但在这种情况下没有帮助。我是不是做错了什么，还是真的有问题？
我附上了这个问
浏览 2提问于2013-07-29得票数 0
回答已采纳
我正在学习Java，并且能够使用runnable对我现有的应用程序进行一些多线程处理。我现在正在研究disruptor(在线程之间共享变量)，但我不知道作者实际上是如何产生线程的。
我看到他在使用Executor，我用它在我的程序中提交runnable类，但在这个例子中没有submit (或runnable)。我只从Oracle教程中学到了我所知道的，它们提到了唯一的两种方法是扩展线程或实现runnable(我在这里看不到这两种方法，但他确实将executor提交给disruptor，这可能是他是如何线程化的？)是我漏掉了什么，还是这个人用了不同的方式？我的最终目标是理解这段代码(它可以完美地
浏览 3提问于2012-03-14得票数 2
回答已采纳
我正在尝试在低延迟环境中登录。
两个高优先级线程在紧循环中调用log.error() (1M消息/s)
我希望使用异步日志记录(与中断程序一起)，并丢弃任何多余的消息。所以调用线程不应该阻塞。
然而，j堆栈清楚地显示它阻塞了大约100次/s。
是我的配置错了吗？或者，如果缓冲区被填满，阻塞是否不可避免？
java -Log4jContextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector
-Dlog4j2.AsyncQueueFullPolicy=Discard
-Dlog4j2.DiscardThr
浏览 4提问于2017-02-14得票数 4
回答已采纳
正如在中所解释的，我需要先用Unmarchaler处理RingBuffer的事件，然后再用Business处理。假设它配置为()
Disruptor<MyEvent> disruptor = new Disruptor<MyEvent>(MyEvent.FACTORY, 32, Executors.newCachedThreadPool());
EventHandler<MyEvent> handler1 = new EventHandler<MyEvent>() { ... };
EventHandler<MyEvent>
浏览 6提问于2017-01-18得票数 0
回答已采纳
在“lmax disruptor架构设计”中，它表明，他们在input disruptor中获取输入并查询它，有多个事件处理程序，如日志记录、解组、业务逻辑，然后再将其查询到输出中断程序，输出disruptor有编组、日志记录等事件处理程序。 我的疑问是..why没有使用一个中断程序和所有输入和输出中断程序的组合事件处理程序。我们可以这样处理事件:在业务逻辑处理之后，输出的中断器事件将调用。 如果我误解了，请纠正我。
浏览 18提问于2019-05-08得票数 2
回答已采纳
我在玩弄框架，发现我的事件处理程序没有被调用。
这是我的设置代码：
private static final int BUFFER_SIZE = 1024 * 8;
private final ExecutorService EXECUTOR = Executors.newSingleThreadExecutor();
private void initializeDisruptor() {
if (disruptor != null)
return;
disruptor =
new Disruptor<TwitterSta
浏览 10提问于2011-11-29得票数 6
回答已采纳
我最近被介绍给LMAX Disruptor，并决定试一试。多亏了开发人员，安装过程迅速而轻松。但我想如果有人能帮我的话，我会遇到麻烦。
问题：I被告知，当生产者发布事件时，它应该阻塞，直到消费者有机会在包装之前检索它。我在消费者端设置了一个序列屏障，我可以确认，如果没有生产者发布的数据，消费者的waitFor调用将被阻塞。但是，生产者似乎没有受到任何方式的监管，只会在环形缓冲区中对未处理的数据进行包装和覆盖。
我有一个生产者作为运行对象运行在单独的线程上。
public class Producer implements Runnable {
private final RingBuf
浏览 2提问于2018-05-27得票数 0
我有来自不同来源(多播、tcp)的不同数据。我打算使用不同的Disruptor来单独管理每种类型的数据，而我希望通过一个线程使用所有这些数据。
这样的模型Disruptor是为什么而设计的？如果是这样的话，中断构造函数附带了Executor / ThreadFactory，这意味着里面的数据应该由线程池管理。我们如何将同一线程共享给多个disruptor？
浏览 8提问于2018-03-27得票数 0
我在camel中设置了以下路由。我已经在这里发布了完整的代码。在ProcessorTwo被调用之后，我期望ProcessorOnComplete被调用，但它根本没有被触发。我在这里错过了什么？
公共类CamelRoute扩展了RouteBuilder {
@Override
public void configure() throws Exception {
from("disruptor:routingChannel?concurrentConsumers=10")
.onCompletion()
浏览 2提问于2018-12-07得票数 0
1回答
我为一些业务逻辑使用了一个中断器，它发布到另一个处理IO的中断器。发布到IO中断器的事件可能到达得太快，无法构建和验证IO。嗯，这就是问题的关键...
IO中断器的设置如下：
disruptor = new Disruptor<>(factory, RING_SIZE, executor, ProducerType.SINGLE, new BlockingWaitStrategy());
disruptor.handleEventsWith(new Logic(disruptor, io));
然后，逻辑事件处理程序设置如下：
public void onEvent(FixEven
浏览 0提问于2015-09-03得票数 0
对于LMAX Disruptor 的开发人员/用户：
我的问题是:有人能建议如何将超时函数应用于Disruptor，例如使用EventHandler吗？
下面是我的工作中出现的一个场景：
发件箱--通过网络收件箱发送给服务器的消息--从服务器 Handler接收到的ACK消息--将发送框消息标记为ACKed超时处理程序--将发送框消息标记为NACKed (非常需要，但它在哪里可以适合Disruptor设计？)<code>G 210</code>
有谁有相同的观点吗？或者有人能指出为什么这是不必要的。我希望随后的辩论简短。
谢谢。
浏览 0提问于2012-02-27得票数 1
我希望使用dirsuptor循环缓冲区来解析一个文件。但是，我不知道如何设置一个范围的值到环缓冲区。
在下面的例子中。它循环到每个项以将其分配给缓冲区。但是我，我想直接分配x项。
当我执行FileInputStream.read( byte[]字节)时，我希望将这些字节放入环形缓冲区。
通常，我的缓冲区比我读取的字节大两倍。像这样，在计算一个页面时，我可以读取另一个页面(例如字节、数组长度、==缓冲区/2 )：
ExecutorService exec = Executors.newCachedThreadPool();
// Preallocate RingBuffer with 1024
浏览 1提问于2014-03-24得票数 0
回答已采纳
我已经运行了由Aleskey Shipilev编写的这个Aleskey Shipilev镜像基准测试，其中比较了ForkJoin和Disruptor库的性能。
我在Linux平台i5上使用JDK1.8.40的结果如下：
Benchmark Score, Score Error (99.9%),Unit,Param: slicesK,
Disruptor.run, 939.801405, 20.741961,ms/op, 50000,0,10
ForkJoin.run, 1175.26
浏览 3提问于2015-06-01得票数 4
回答已采纳
1回答
我们已经在生产中使用了近一年的LMAX消毒器。一切都很好，直到上个星期，我们看到了来自Disruptor的信息。我们的Disruptor结构非常简单：
卡夫卡-> RingBuffer -> Eventhandler1 -> Eventhandler2 -> Eventhandler3
每个Eventhandler都有一个尝试捕获块来捕获所有异常。最慢的是Eventhandler2，每条消息需要3毫秒。
我们向Kafaka发送了53条消息，它们都是由Eventhandler1处理的。但是Eventhandler2和Eventhandler3只接收了23条消息，我们在日志
浏览 7提问于2017-03-16得票数 3
我通过调用tryPublishEvent函数将数据添加到中断程序中。在我等待了40秒并尝试通过以下计算检查unprocessedDataCount之后：
long ringBufferUnProcessedCount = disruptor.getBufferSize()
- disruptor.getRingBuffer().remainingCapacity()
有时remainingCapacity值等于0，即使在获得ringBufferUnProcessedCount值之前我们等待了40秒。这种错误很少发生。
你不知
浏览 14提问于2021-02-26得票数 0
我发现github中的Lmax Disruptor的用户指南非常简单，现在我有一个生产者和五个消费者的问题，之后我需要总结消费者的结果，有任何演示，如何找到Lmax Disruptor钻石(一个生产者5消费者1结论)的例子？
非常感谢！
浏览 14提问于2015-02-03得票数 1
LMAX Disruptor的示例代码“开始”..。
public class LongEvent
{
private long value;
public void set(long value)
{
this.value = value;
}
}
参考文献：
为什么private long value没有被声明为volatile
我之所以这样问是因为，对于Disruptor模式来说，数据是在线程之间共享的(生产者->使用者)。
我猜:在生产者和使用者线程之间已经(至少)有一个内存围栏。
浏览 2提问于2016-01-10得票数 3
回答已采纳
1回答
我有以下场景。 我们在K8s的云中对我们的应用程序进行了负载测试。我们的入站消息是通过Kafka发送的，我们正在给Kafka回信。我们的架构是这样的: Kafka线程将消息推送到disruptor (阻塞等待策略，512大小)，业务线程将消息从disruptor中取出进行处理。为了模拟负载，我们在Kafka主题(4个分区)中设置了应用程序未运行时的关闭500K消息。然后，我们启动应用程序来测量负载。 我们看到的是，disruptor完全填满了剩余的0容量，然后开始耗尽，这种情况一次又一次地继续下去。 这是正确的行为，还是我们以错误的方式使用颠覆者？请分享你的想法？
浏览 35提问于2020-07-21得票数 0
2回答
对骆驼来说很新鲜。我需要监听一个处理管道，检查内部的事件，并发送statsd指标。代码看起来应该如下所示：
Processor statsdProcessor = new StatsDProcessor();
...
from("disruptor:wiretap").process(statsdProcessor);
disruptor:wiretap已经连接到主管道。
我想知道在没有to()端点的情况下使用prossor意味着什么？exchanges是否会在内存中停留，因为在超时之前没有任何去处，或者因为缓冲区已满而被覆盖？
浏览 1提问于2014-09-22得票数 3
回答已采纳
我最近发现，使用条件赋值(?=)设置特定于目标的变量，其效果是使用相同的名称取消导出全局变量。
例如：target: CFLAGS ?= -O2
如果该语句位于Makefile中的任何位置，则它对全局变量的影响与unexport CFLAGS相同。
这意味着作为环境变量传递给CFLAGS的Makefile不会作为环境变量传递给任何子makefile，就好像它从未被设置过一样。
它会是一个make错误吗？我在里找不到任何关于这个副作用的东西。
示例:根Makefile
target:
$(MAKE) -C $(DIR) target
disruptor: CFLAGS ?= -O1
d
浏览 5提问于2020-12-01得票数 0
回答已采纳
1回答
我是破坏者的新手，我使用干扰器在类似管道的结构中在线程之间传递，我可以运行一组处理程序，如下所示，使用hadleEventsWith或使用after()。
disruptor.handleEventsWith(eventhandler1)
.then(eventhandler2)
.then(eventhandler3);
但是，我希望能够在不改变代码EventHandlers的情况下向这个管道中添加新的here.To，我将向每个事件handler.Then添加一个整数值，我将使用这些值和相关的处理程序来创建一个有序的处理程序列表
浏览 4提问于2016-11-10得票数 2
回答已采纳
1回答
从下面的代码或中，为什么我不能执行future2.get()，等待future2完成，然后得到结果？
如果我使用future2.get()，它将永远等待。
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.ut
浏览 2提问于2011-09-01得票数 1
回答已采纳
LMX disruptor的屏障是如何工作的？我知道如何在DSL中使用disruptor。但我找不到一个很好的参考来说明屏障或序列屏障是如何工作的。
例如，我找到了下面的链接，但不确定如何使用Barrier数据结构。
例如，新的BatchEventProcessor()接受一个SequenceBarrier。为什么？我怎样才能创建一个。
浏览 5提问于2013-06-27得票数 1
1回答
我正在使用OpaqueTridentKafkaSpout消费来自卡夫卡的信息。下面是密码。我忽略了max spout pending配置，因为这会导致相同的kafka消息在多个批中到达。
TridentKafkaConfig tridentKafkaConfig = new TridentKafkaConfig(hosts,properties.getProperty("topic", "mytopic"));
tridentKafkaConfig.scheme = new SchemeAsMultiScheme(new StringScheme());
Opa
浏览 1提问于2018-05-24得票数 0
回答已采纳
以前，当我使用单生产者模式的干扰，例如。
new Disruptor<ValueEvent>(ValueEvent.EVENT_FACTORY,
2048, moranContext.getThreadPoolExecutor(), ProducerType.Single,
new BlockingWaitStrategy())
表演很好。现在，我所处的情况是，多个线程将写入单个环缓冲区。我发现，ProducerType.Multi使代码比单个生产者模式慢几倍。那种糟糕的表现我是不会接受的。那么，当多个线程使用锁调用相同的事件发布方法时，我应该使用
浏览 2提问于2013-09-25得票数 4
回答已采纳
干扰器github地址是：
我有一个简单的测试如下：
public class DisruptorMain {
@SuppressWarnings({ "rawtypes", "unchecked" })
public static void main(String[] args) throws Exception {
class Element {
private int value;
public int get() {
return valu
浏览 1提问于2018-01-20得票数 2
回答已采纳
使用Disruptor ring buffer，我每秒只能获得600万次操作。我想知道我哪里错了。我的事件处理程序只是侦测一个计数器。这是单一生产者和单一消费者的情况。有没有人能告诉我我的语义本身是不是错了。该程序创建一个生产者线程，该线程添加到缓冲区中。并创建一个事件处理程序来处理发布事件。每次发布事件时，eventhandler都会递增一个易失性计数器。
public class MainClass{
public static class globalVariables
{
static int NUMBER_OF_ITERATIONS = 33554432
浏览 5提问于2013-12-02得票数 0
我想使用python客户端消费消息并将其发布到wso2消息代理。我搜索了很多次，没有找到任何专门为wso2消息代理设计的python客户端。
尽管我知道适用于rabbitmq的pika库也适用于wso2 message broker。
因此，我编写了一段代码来将消息发布到wso2队列。我在wso2 message broker上创建了一个测试队列，并尝试使用pika库发布消息。
import pika
params = pika.URLParameters("amqp://admin:admin@localhost:5672/%2F")
connection = pika.B
浏览 1提问于2017-08-04得票数 0
回答已采纳
2回答
我以堆栈溢出问题中的代码示例为例，并将其修改为“度量”时间。完整的名单如下：
using System;
using System.Diagnostics;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Disruptor;
using Disruptor.Dsl;
namespace DisruptorTest
{
public sealed class ValueEntry
{
public long Value { get; set; }
浏览 2提问于2012-11-11得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
