Examples of com.lmax.disruptor.BusySpinWaitStrategy

com.lmax.disruptor.BusySpinWaitStrategy
Busy Spin strategy that uses a busy spin loop for {@link com.lmax.disruptor.EventProcessor}s waiting on a barrier. This strategy will use CPU resource to avoid syscalls which can introduce latency jitter. It is best used when threads can be bound to specific CPU cores.

            case "yielding":
                return new YieldingWaitStrategy();
            case "blocking":
                return new BlockingWaitStrategy();
            case "busy_spinning":
                return new BusySpinWaitStrategy();
            default:
                LOG.warn("Invalid setting for [processor_wait_strategy]:"
                        + " Falling back to default: BlockingWaitStrategy.");
                return new BlockingWaitStrategy();
        }

View Full Code Here

                    @Override
                    public PathTrackingEntry newInstance()
                    {
                        return new PathTrackingEntry();
                    }
                }, ringBufferSize, exec, ProducerType.SINGLE, new BusySpinWaitStrategy()
                );


                for ( int i = 0; i < numberOfConsumers; i++ )
                {
                    disruptor.handleEventsWith( new PathTrackingEntryEventHandler( i, numberOfConsumers, this.pathTrackingDataStore ) );

View Full Code Here

            @Override
            public PathTrackingEntry newInstance()
            {
                return new PathTrackingEntry();
            }
        }, ringBufferSize, exec, ProducerType.SINGLE, new BusySpinWaitStrategy()
        );


        for ( int i = 0; i < numberOfConsumers; i++ )
        {
            disruptor.handleEventsWith( new PathTrackingEntryEventHandler( i, numberOfConsumers ) );

View Full Code Here

        workers = Executors.newFixedThreadPool(numEventProcessors, new DaemonThreadFactory(nameForThreads));


        ringBuffer = new RingBuffer<E>(
                eventFactory,
                new MultiThreadedClaimStrategy(bufferSize),
                new BusySpinWaitStrategy());


        WorkProcessor<E> processor = null;
        for (WorkHandler<E> handler : handlers) 
        {
            processor = scheduleEventProcessor(processor, handler);

View Full Code Here

        private final WaitStrategy waitStrategy;


        @SuppressWarnings("UnusedDeclaration")
        private WaitStrategyFactoryBean(String strategyName) {
            if ("busy-spin".equals(strategyName)) {
                waitStrategy = new BusySpinWaitStrategy();
            } else if ("yield".equals(strategyName)) {
                waitStrategy = new YieldingWaitStrategy();
            } else if ("sleep".equals(strategyName)) {
                waitStrategy = new SleepingWaitStrategy();
            } else if ("block".equals(strategyName)) {

View Full Code Here

TOP

Related Classes of com.lmax.disruptor.BusySpinWaitStrategy

org.apache.sirona.collector.server.Collector

org.apache.sirona.cube.DisruptorPathTrackingDataStore

org.axonframework.contextsupport.spring.DisruptorCommandBusBeanDefinitionParser$WaitStrategyFactoryBean

org.graylog2.plugin.BaseConfiguration

org.neo4j.smack.pipeline.RingBufferWorkPipeline

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.