Disruptor 源码分析(8) 生产者和消费者默认的等待策略
disruptor生产者和消费者默认的等待策略

生产者和消费者都可能出现速度过快,追上对方的情况,这个时候就需要等待了.等待过程中也会有不同的策略.

生产者的默认策略是BlockingWaitStrategy,是在RingBuffer中确定的.但是生产者的默认实现MultiProducerSequencer没有使用等待策略.

 public static <E> RingBuffer<E> createMultiProducer(EventFactory<E> factory, int bufferSize)    {        return createMultiProducer(factory, bufferSize, new BlockingWaitStrategy());    }

MultiProducerSequencer的默认策略是BlockingWaitStrategy.

sequencer其实就是生产者,所以其实消费者的默认策略和生产者是一样的.