簡單用法

下面以一個簡單的例子來看看Disruptor的用法:生產(chǎn)者發(fā)送一個long型的消息,消費者接收消息并打印出來。

首先,我們定義一個Event:

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

為了使Disruptor對這些Event提前分配,我們需要創(chuàng)建一個EventFactory:

        		

網(wǎng)友評論