簡單用法
下面以一個簡單的例子來看看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)友評論