簡(jiǎn)單用法

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

首先,我們定義一個(gè)Event:

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

為了使Disruptor對(duì)這些Event提前分配,我們需要?jiǎng)?chuàng)建一個(gè)EventFactory:

        		

網(wǎng)友評(píng)論