docs: private int pollRemovedCountHolders(AtomicReferenceArray<Queue<Integer>> removedCountHolders) {
          int count = 0;
          for (int i = 0; i < partitionCount; i++) {
              Queue<Integer> removalCounts = removedCountHolders.get(i);
              count += removalCounts.poll();
          }
          return count;
      }