Package com.helix.core.stream.disruptor

Class DisruptorConfig.Builder

java.lang.Object

com.helix.core.stream.disruptor.DisruptorConfig.Builder

Enclosing class:

DisruptorConfig

public static class DisruptorConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
DisruptorConfig.Builder	blockingWaitStrategy()
DisruptorConfig	build()
DisruptorConfig.Builder	busySpinWaitStrategy()
DisruptorConfig.Builder	multiProducer()
DisruptorConfig.Builder	producerType(com.lmax.disruptor.dsl.ProducerType producerType)
DisruptorConfig.Builder	ringBufferSize(int ringBufferSize)
DisruptorConfig.Builder	singleProducer()
DisruptorConfig.Builder	threadFactory(ThreadFactory threadFactory)
DisruptorConfig.Builder	waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)
DisruptorConfig.Builder	yieldingWaitStrategy()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Builder

public Builder()

Method Details

ringBufferSize

public DisruptorConfig.Builder ringBufferSize(int ringBufferSize)

waitStrategy

public DisruptorConfig.Builder waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)

yieldingWaitStrategy

public DisruptorConfig.Builder yieldingWaitStrategy()

busySpinWaitStrategy

public DisruptorConfig.Builder busySpinWaitStrategy()

blockingWaitStrategy

public DisruptorConfig.Builder blockingWaitStrategy()

producerType

public DisruptorConfig.Builder producerType(com.lmax.disruptor.dsl.ProducerType producerType)

singleProducer

public DisruptorConfig.Builder singleProducer()

multiProducer

public DisruptorConfig.Builder multiProducer()

threadFactory

public DisruptorConfig.Builder threadFactory(ThreadFactory threadFactory)

build

public DisruptorConfig build()