Method PushTask

cpp/src/arrow/acero/sorted_merge_node.cc:367–380

  }

  void PushTask(bool ok) {
#ifdef ARROW_ENABLE_THREADING
    process_queue.Push(ok);
#else
    if (process_task.is_finished()) {
      return;
    }
    if (ok == kNewTask) {
      PollOnce();
    } else {
      EndFromProcessThread();
    }
#endif
  }

  arrow::Status InputFinished(arrow::acero::ExecNode* input, int total_batches) override {
    ARROW_DCHECK(std_has(inputs_, input));