MCPcopy Create free account
hub / github.com/apache/arrow / TestFinishNeverStarted

Function TestFinishNeverStarted

cpp/src/arrow/util/task_group_test.cc:330–335  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

328}
329
330void TestFinishNeverStarted(std::shared_ptr<TaskGroup> task_group) {
331 // If we call FinishAsync we are done adding tasks so if we never added any it should be
332 // completed
333 auto finished = task_group->FinishAsync();
334 ASSERT_TRUE(finished.Wait(1));
335}
336
337void TestFinishAlreadyCompleted(std::function<std::shared_ptr<TaskGroup>()> factory) {
338 // If we call FinishAsync we are done adding tasks so even if no tasks are running we

Callers 1

TESTFunction · 0.85

Calls 2

FinishAsyncMethod · 0.45
WaitMethod · 0.45

Tested by

no test coverage detected