Package com.lmax.disruptor

Examples of com.lmax.disruptor.BlockingWaitStrategy

146
147
148
149
150
151
152
153
154
155
156
157
158
159
            case "sleeping":
                return new SleepingWaitStrategy();
            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
68
69
70
71
72
73
74
75
76
77
78
        ProcessBufferProcessor processBufferProcessor = mock(ProcessBufferProcessor.class);
        ProcessBufferProcessor[] processBufferProcessors = new ProcessBufferProcessor[1];
        processBufferProcessors[0] = processBufferProcessor;

        processBuffer.initialize(processBufferProcessors, 1, new BlockingWaitStrategy(), 1);

        Message message = mock(Message.class);
        MessageInput messageInput = mock(MessageInput.class);

        processBuffer.insertFailFast(message, messageInput);
View Full Code Here
145
146
147
148
149
150
151
            }
        }
    }

    private static DisruptorQueue createQueue(String name, int queueSize) {
        return new DisruptorQueue(name, ProducerType.MULTI, queueSize, new BlockingWaitStrategy());
    }
View Full Code Here
174
175
176
177
178
179
180
181
182
183
        if ("Sleep".equals(strategy)) {
            return new SleepingWaitStrategy();
        } else if ("Yield".equals(strategy)) {
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
        return new BlockingWaitStrategy();
    }
View Full Code Here
173
174
175
176
177
178
179
180
181
182
        if ("Sleep".equals(strategy)) {
            return new SleepingWaitStrategy();
        } else if ("Yield".equals(strategy)) {
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
        return new BlockingWaitStrategy();
    }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
        if ("Sleep".equals(strategy)) {
            return new SleepingWaitStrategy();
        } else if ("Yield".equals(strategy)) {
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
        return new BlockingWaitStrategy();
    }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
        } 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
124
125
126
127
128
129
130
131
132
133
        } 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
173
174
175
176
177
178
179
180
181
182
        if ("Sleep".equals(strategy)) {
            return new SleepingWaitStrategy();
        } else if ("Yield".equals(strategy)) {
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
        return new BlockingWaitStrategy();
    }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
        if ("Sleep".equals(strategy)) {
            return new SleepingWaitStrategy();
        } else if ("Yield".equals(strategy)) {
            return new YieldingWaitStrategy();
        } else if ("Block".equals(strategy)) {
            return new BlockingWaitStrategy();
        }
        LOGGER.debug("disruptor event handler uses BlockingWaitStrategy");
        return 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.