Searched refs:DisruptorEventQueue (Results 1 – 5 of 5) sorted by relevance
90 public final class DisruptorEventQueue implements EventQueue { class92 private static final Logger logger = Logger.getLogger(DisruptorEventQueue.class.getName());101 private static final DisruptorEventQueue eventQueue = create();111 private DisruptorEventQueue( in DisruptorEventQueue() method in DisruptorEventQueue121 private static DisruptorEventQueue create() { in create()149 return new DisruptorEventQueue(disruptor, ringBuffer, enqueuer); in create()157 public static DisruptorEventQueue getInstance() { in getInstance()
19 import io.opencensus.impl.internal.DisruptorEventQueue;29 super(DisruptorEventQueue.getInstance(), MillisClock.getInstance()); in StatsComponentImpl()
20 import io.opencensus.impl.internal.DisruptorEventQueue;41 DisruptorEventQueue.getInstance()); in TraceComponentImpl()
20 import io.opencensus.impl.internal.DisruptorEventQueue;40 DisruptorEventQueue.getInstance()); in TraceComponentImpl()
78 DisruptorEventQueue.getInstance().enqueue(ie); in incrementOnce()94 DisruptorEventQueue.getInstance().enqueue(ie); in incrementTenK()