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

Function SpawnReal

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

Source from the content-addressed store, hash-verified

1088 bool IsCurrentExecutor() override { return pool_->IsCurrentExecutor(); }
1089
1090 Status SpawnReal(internal::TaskHints hints, internal::FnOnce<void()> task,
1091 StopToken stop_token, StopCallback&& stop_callback) override {
1092 ++spawn_count;
1093 return pool_->Spawn(hints, std::move(task), std::move(stop_token),
1094 std::move(stop_callback));
1095 }
1096
1097 std::atomic<int> spawn_count{0};
1098 internal::Executor* pool_ = internal::GetCpuThreadPool();

Callers 2

SpawnFunction · 0.85
SubmitFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected