Function TestFinishAlreadyCompleted

cpp/src/arrow/util/task_group_test.cc:337–351

}

void TestFinishAlreadyCompleted(std::function<std::shared_ptr<TaskGroup>()> factory) {
  // If we call FinishAsync we are done adding tasks so even if no tasks are running we
  // should still be completed
  const int NTASKS = 100;
  for (int i = 0; i < NTASKS; ++i) {
    auto task_group = factory();
    // Add a task and let it complete
    task_group->Append([] { return Status::OK(); });
    // Wait a little bit, hopefully enough time for the task to finish on one of these
    // iterations
    SleepFor(1e-2);
    auto finished = task_group->FinishAsync();
    ASSERT_FINISHES_OK(finished);
  }
}

TEST(SerialTaskGroup, Success) { TestTaskGroupSuccess(TaskGroup::MakeSerial()); }