code: protected void syncCompactor() {
          ConcurrentLinkedQueue<Segment> queue = _compactor.getCompactedQueue();
          while(!queue.isEmpty()) {
              Segment seg = queue.remove();
              consumeCompactionBatches();
              _compactor.getFreeQueue().offer(seg);
          }
          
          consumeCompactionBatches();
      }
docs: Sync with the Segment compactor to consume all the produced {@link CompactionUpdateBatch}(es).