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

Method SpawnAddsThreaded

cpp/src/arrow/util/thread_pool_test.cc:556–560  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

554 }
555
556 void SpawnAddsThreaded(ThreadPool* pool, int nthreads, int nadds, AddTaskFunc add_func,
557 StopToken stop_token = StopToken::Unstoppable()) {
558 DoSpawnAddsThreaded(pool, nthreads, nadds, std::move(add_func),
559 std::move(stop_token));
560 }
561
562 void SpawnAddsThreadedAndCancel(ThreadPool* pool, int nthreads, int nadds,
563 AddTaskFunc add_func, StopSource* stop_source) {

Callers

nothing calls this directly

Calls 1

UnstoppableFunction · 0.85

Tested by

no test coverage detected