Method BeginExternalTask

cpp/src/arrow/acero/query_context.cc:52–59

size_t QueryContext::max_concurrency() const { return thread_indexer_.Capacity(); }

Result<Future<>> QueryContext::BeginExternalTask(std::string_view name) {
  Future<> completion_future = Future<>::Make();
  if (async_scheduler_->AddSimpleTask([completion_future] { return completion_future; },
                                      name)) {
    return completion_future;
  }
  return Future<>{};
}

void QueryContext::ScheduleTask(std::function<Status()> fn, std::string_view name) {
  ::arrow::internal::Executor* exec = executor();