java - Disruptor如何使用他的环形缓冲区来读取文件？

Question

我正在寻找使用 dirsuptor 环形缓冲区来解析文件。但我不知道如何为环形缓冲区设置一个值范围。

在下面的例子中似乎是这样。它循环到每个项目以将其分配给缓冲区。但我，我想直接分配x个项目。

当我执行 FileInputStream.read( byte[] bytes ) 时，我想将这些字节放入环形缓冲区中。

通常我的缓冲区比我读取的字节大两倍。像这样，我可以在计算一页时读取另一页(例如字节数组长度==缓冲区/2):

ExecutorService exec = Executors.newCachedThreadPool();
// Preallocate RingBuffer with 1024 ValueEvents
Disruptor<ValueEvent> disruptor = new Disruptor<ValueEvent>(ValueEvent.EVENT_FACTORY, 1024, exec);

// Build dependency graph
RingBuffer<ValueEvent> ringBuffer = disruptor.start();

for (long i = 10; i < 2000; i++) {
    String uuid = UUID.randomUUID().toString();
    // Two phase commit. Grab one of the 1024 slots
    long seq = ringBuffer.next();
    ValueEvent valueEvent = ringBuffer.get(seq);
    valueEvent.setValue(uuid);
    ringBuffer.publish(seq);
}

谢谢

Answer 1

自版本 3.0.0支持批量发布Disruptor。

Ringbuffer 上有多种 publishEvents 方法，具体取决于您希望如何转换事件。

鉴于您的示例代码，我怀疑您想查看 this版本，并提供一个 UUID 数组。有多个版本，具体取决于您希望传递给翻译器的参数数量。

alternative version是在 EventTranslator 自身中捕获 UUID。