简单用法
下面以一个简单的例子来看看Disruptor的用法:生产者发送一个long型的消息,消费者接收消息并打印出来。
首先,我们定义一个Event:
public class LongEvent{ private long value; public void set(long value) { this.value = value; } }
为了使Disruptor对这些Event提前分配,我们需要创建一个EventFactory:
网友评论
下面以一个简单的例子来看看Disruptor的用法:生产者发送一个long型的消息,消费者接收消息并打印出来。
首先,我们定义一个Event:
public class LongEvent{ private long value; public void set(long value) { this.value = value; } }
为了使Disruptor对这些Event提前分配,我们需要创建一个EventFactory:
网友评论