（LMAX破坏者）如何自己获取数据而不是通过回调？

Question

我了解到 LMAX 中断器是一个高性能的线程间消息传递库。 但是当我尝试使用它时，我发现事件处理程序使用回调方法来处理数据。

void onEvent(T event,
       long sequence,
       boolean endOfBatch)
         throws java.lang.Exception

当发布者向 RingBuffer 发布事件时调用

但是如果我不使用回调来获取数据，我自己写了一个while(true)来获取数据，我该怎么办？

谢谢！

Answer 1

您应该编写回调，以便将事件推送到队列中。然后您可以遍历队列。

Queue<Event> queue = new ArrayBlockingQueue(10);

void onEvent(Event event,
        long sequence,
        boolean endOfBatch)
        throws java.lang.Exception {
    queue.add(event);
}

public void test() {
    for ( Event event : queue ) {
        // Your stuff here.
    }
}