Package com.lmax.disruptor

Examples of com.lmax.disruptor.BlockingWaitStrategy

498
499
500
501
502
503
504
505
506
507
508
      this.conf.getInt("hbase.regionserver.wal.disruptor.event.count", 1024 * 16);
    // Using BlockingWaitStrategy.  Stuff that is going on here takes so long it makes no sense
    // spinning as other strategies do.
    this.disruptor =
      new Disruptor<RingBufferTruck>(RingBufferTruck.EVENT_FACTORY, preallocatedEventCount,
        this.appendExecutor, ProducerType.MULTI, new BlockingWaitStrategy());
    // Advance the ring buffer sequence so that it starts from 1 instead of 0,
    // because SyncFuture.NOT_DONE = 0.
    this.disruptor.getRingBuffer().next();
    this.ringBufferEventHandler =
      new RingBufferEventHandler(conf.getInt("hbase.regionserver.hlog.syncer.count", 5),
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
     * multi-threaded producer type.
     */
    public DisruptorConfiguration() {
        this.bufferSize = DEFAULT_BUFFER_SIZE;
        this.producerType = ProducerType.MULTI;
        this.waitStrategy = new BlockingWaitStrategy();
        coolingDownPeriod = 1000;
        cache = NoCache.INSTANCE;
        rescheduleCommandsOnCorruptState = true;
        rollbackConfiguration = new RollbackOnUncheckedExceptionConfiguration();
        commandTargetResolver = new AnnotationCommandTargetResolver();
View Full Code Here
132
133
134
135
136
137
138
139
140
141
        } else if ("Yield".equals(strategy)) {
            LOGGER.debug("disruptor event handler uses YieldingWaitStrategy");
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses SleepingWaitStrategy");
        return new SleepingWaitStrategy();
    }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
        } else if ("Yield".equals(strategy)) {
            LOGGER.debug("disruptor event handler uses YieldingWaitStrategy");
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses SleepingWaitStrategy");
        return new SleepingWaitStrategy();
    }
View Full Code Here
63
64
65
66
67
68
69
70
71
    public void start() {
        executorService = Executors.newCachedThreadPool();
        disruptor = new Disruptor<Registration>(Registration.FACTORY,
                executorService,
                new MultiThreadedClaimStrategy(ringSize),
                new BlockingWaitStrategy());
        disruptor.handleEventsWith(new ContainerEventHandler());
        ringBuffer = disruptor.start();
    }
View Full Code Here
313
314
315
316
317
318
319
320
321
322
323
            } else if ("yield".equals(strategyName)) {
                waitStrategy = new YieldingWaitStrategy();
            } else if ("sleep".equals(strategyName)) {
                waitStrategy = new SleepingWaitStrategy();
            } else if ("block".equals(strategyName)) {
                waitStrategy = new BlockingWaitStrategy();
            } else {
                throw new IllegalArgumentException("WaitStrategy is not one of the allowed values: "
                                                           + "busy-spin, yield, sleep or block.");
            }
        }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
    }

    private void run(String[] args) throws InterruptedException {

        // This is to keep my MBA from catching on fire...
        WaitStrategy waitStrategy = new BlockingWaitStrategy();

        RingBuffer<MarketEvent> ringBuffer = new RingBuffer<MarketEvent>(MarketEvent.FACTORY, getClaimStrategy(),
                waitStrategy);

        // Initial barrier
View Full Code Here
86
87
88
89
90
91
92
     * @param bufferSize number of elements to create within the ring buffer.
     * @throws IllegalArgumentException if <tt>bufferSize</tt> is less than 1 or not a power of 2
     */
    public static <E> RingBuffer<E> createMultiProducer(EventFactory<E> factory, int bufferSize)
    {
        return createMultiProducer(factory, bufferSize, new BlockingWaitStrategy());
    }
View Full Code Here
117
118
119
120
121
122
123
     * @param bufferSize number of elements to create within the ring buffer.
     * @throws IllegalArgumentException if <tt>bufferSize</tt> is less than 1 or not a power of 2
     */
    public static <E> RingBuffer<E> createSingleProducer(EventFactory<E> factory, int bufferSize)
    {
        return createSingleProducer(factory, bufferSize, new BlockingWaitStrategy());
    }
View Full Code Here
537
538
539
540
541
542
543
    // }else {
    // claimStrategy = new MultiThreadedClaimStrategy(queueSize);
    // }

    return new DisruptorQueue(name, type, queueSize,
        new BlockingWaitStrategy());
  }
View Full Code Here
TOP

Related Classes of com.lmax.disruptor.BlockingWaitStrategy

  • backtype.storm.utils.disruptor.RingBuffer
  • backtype.storm.utils.DisruptorQueueTest
  • be.eliwan.profiling.service.ProfilingContainer
  • com.alibaba.jstorm.util.queue.DisruptorTest
  • com.lmax.disruptor.dsl.DisruptorTest
  • com.lmax.disruptor.example.TwoDisruptors
  • org.apache.hadoop.hbase.regionserver.wal.FSHLog
  • org.apache.logging.log4j.core.async.AsyncLogger
  • org.apache.logging.log4j.core.async.AsyncLoggerConfigHelper
  • org.axonframework.commandhandling.disruptor.DisruptorConfiguration
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.