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

Method SetFinishedDeferred

cpp/src/arrow/util/future_test.cc:129–133  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

127 }
128
129 void SetFinishedDeferred(std::vector<std::pair<int, bool>> pairs) {
130 std::this_thread::sleep_for(kYieldDuration);
131 ABORT_NOT_OK(
132 pool_->Spawn([this, pairs = std::move(pairs)]() { SetFinished(pairs); }));
133 }
134
135 // Mark future successful
136 void SetFinished(int fut_index) { futures_[fut_index].MarkFinished(T(fut_index)); }

Callers 3

TestBasicWaitMethod · 0.80
TestTimedWaitMethod · 0.80
TestStressWaitMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected