Method EnqueueRanges

be/src/exec/scan-range-queue-mt.h:43–54

Adds all scan ranges to the queue. If 'high_prio' is true we add it to a separate list of prioritized items.

  /// Adds all scan ranges to the queue. If 'high_prio' is true we add it to a separate
  /// list of prioritized items.
  void EnqueueRanges(const std::vector<io::ScanRange*>& ranges, bool high_prio) {
    std::lock_guard<std::mutex> lock(scan_range_queue_lock_);
    if (LIKELY(!high_prio)) {
      for (io::ScanRange* scan_range : ranges) {
        scan_range_queue_.Push(scan_range);
      }
    } else {
      for (io::ScanRange* scan_range : ranges) {
        high_prio_scan_ranges_.push(scan_range);
      }
    }
  }

  /// Returns the next scan range from the queue. Returns nullptr if the queue is empty.
  io::ScanRange* Dequeue() {