Method Dequeue

be/src/exec/scan-range-queue-mt.h:57–67

Returns the next scan range from the queue. Returns nullptr if the queue is empty.

  /// Returns the next scan range from the queue. Returns nullptr if the queue is empty.
  io::ScanRange* Dequeue() {
    io::ScanRange* ret = nullptr;
    std::lock_guard<std::mutex> lock(scan_range_queue_lock_);
    if (UNLIKELY(!high_prio_scan_ranges_.empty())) {
      ret = high_prio_scan_ranges_.front();
      high_prio_scan_ranges_.pop();
    } else if (!scan_range_queue_.Empty()) {
      ret = scan_range_queue_.Pop();
    }
    return ret;
  }

  /// Returns true if the scan range queue is empty.
  bool Empty() {