简单用法

下面以一个简单的例子来看看Disruptor的用法:生产者发送一个long型的消息,消费者接收消息并打印出来。

首先,我们定义一个Event:

public class LongEvent{    private long value;    public void set(long value)
    {        this.value = value;
    }
}

为了使Disruptor对这些Event提前分配,我们需要创建一个EventFactory:

        		

网友评论