Searched refs:disruptor (Results 1 – 5 of 5) sorted by relevance
19 import com.lmax.disruptor.EventFactory;20 import com.lmax.disruptor.EventHandler;21 import com.lmax.disruptor.RingBuffer;22 import com.lmax.disruptor.SleepingWaitStrategy;23 import com.lmax.disruptor.dsl.Disruptor;24 import com.lmax.disruptor.dsl.ProducerType;104 private final Disruptor<DisruptorEvent> disruptor; field in DisruptorEventQueue112 Disruptor<DisruptorEvent> disruptor, in DisruptorEventQueue() argument115 this.disruptor = disruptor; in DisruptorEventQueue()125 Disruptor<DisruptorEvent> disruptor = in create() local[all …]
13 libraries.disruptor
180 disruptor: 'com.lmax:disruptor:3.4.1',
96 - Upgrade disruptor to include the fix for SleepingWaitStrategy causing 100%
427 artifact = "com.lmax:disruptor:3.4.1",