Examples of com.lmax.disruptor.MultiProducerSequencer

com.lmax.disruptor.MultiProducerSequencer

Coordinator for claiming sequences for access to a data structure while tracking dependent {@link Sequence}s. Suitable for use for sequencing across multiple publisher threads.

*
Note on {@link Sequencer#getCursor()}: With this sequencer the cursor value is updated after the call to {@link Sequencer#next()}, to determine the highest available sequence that can be read, then {@link Sequencer#getHighestPublishedSequence(long,long)} should be used.

     */
    public static <E> RingBuffer<E> createMultiProducer(EventFactory<E> factory,
                                                        int             bufferSize,
                                                        WaitStrategy    waitStrategy)
    {
        MultiProducerSequencer sequencer = new MultiProducerSequencer(bufferSize, waitStrategy);


        return new RingBuffer<E>(factory, sequencer);
    }

View Full Code Here

TOP

Related Classes of com.lmax.disruptor.MultiProducerSequencer

backtype.storm.utils.disruptor.RingBuffer

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.