Method ScheduleTaskCallback

cpp/src/arrow/acero/tpch_node.cc:3415–3427

  }

  Status ScheduleTaskCallback(std::function<Status(size_t)> func) {
    if (finished_generating_.load()) return Status::OK();
    plan_->query_context()->ScheduleTask(
        [this, func](size_t thread_index) {
          Status status = func(thread_index);
          if (!status.ok()) {
            ARROW_RETURN_NOT_OK(StopProducing());
          }
          return status;
        },
        "TpchNode::GenerateAndProcessBatch");
    return Status::OK();
  }

  const char* name_;
  std::unique_ptr<TpchTableGenerator> generator_;