docs: private static DisruptorEventQueue create() {
      // Create new Disruptor for processing. Note that Disruptor creates a single thread per
      // consumer (see https://github.com/LMAX-Exchange/disruptor/issues/121 for details);
      // this ensures that the event handler can take unsynchronized actions whenever possible.
      Disruptor<DisruptorEvent> disruptor =
          new Disruptor<>(
              DisruptorEventFactory.INSTANCE,
              DISRUPTOR_BUFFER_SIZE,
              new DaemonThreadFactory("OpenCensus.Disruptor"),
              ProducerType.MULTI,
              new SleepingWaitStrategy(0, 1000 * 1000));
      disruptor.handleEventsWith(new DisruptorEventHandler[] {DisruptorEventHandler.INSTANCE});
      disruptor.start();
      final RingBuffer<DisruptorEvent> ringBuffer = disruptor.getRingBuffer();
  
      DisruptorEnqueuer enqueuer =
          new DisruptorEnqueuer() {
            @Override
            public void enqueue(Entry entry) {
              long sequence = ringBuffer.next();
              try {
                DisruptorEvent event = ringBuffer.get(sequence);
                event.setEntry(entry);
              } finally {
                ringBuffer.publish(sequence);
              }
            }
          };
      return new DisruptorEventQueue(disruptor, enqueuer);
    }