HBase中Disruptor使用
// 核心是一个循环缓冲区。我们的循环缓冲区是一个LMAX Disruptor。当多个线程在单个WAL竞争append和sync时,它试图最小化同步与volatile写。 // Disruptor配置为处理多个生产者和仅有一个消费者(HBase中的生产者是调用append、sync的IPC Handlers)。单一的消费者从环形缓冲区中 // 拉去append和sync。 /** * RingBufferTruck为事件--Event * RingBufferTruck.EVENT_FACTORY为事件工厂--EventFactory * preallocatedEventCount为RingBuffer大小,必须是2的N次方,默认为1024*16 * appendExecutor为事件处理的线程池--newSingleThreadExecutor * ProducerType.MULTI为生产者类型,意思为多个生产者 * BlockingWaitStrategy为指定的等待策略 */ this.disruptor = new Disruptor<RingBufferTruck&...