MCPcopy Create free account
hub / github.com/apache/arrow / operator()

Method operator()

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

Source from the content-addressed store, hash-verified

219 Status final_status_;
220
221 Status operator()() {
222 if (!barrier_->load()) {
223 SleepFor(1e-5);
224 // Note the TaskGroup should be kept alive by the fact this task
225 // is still running...
226 weak_group_ptr_.lock()->Append(*this);
227 }
228 return final_status_;
229 }
230};
231
232// Try to replicate subtle lifetime issues when destroying a TaskGroup

Callers

nothing calls this directly

Calls 3

SleepForFunction · 0.85
loadMethod · 0.45
AppendMethod · 0.45

Tested by

no test coverage detected