簡(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)論