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

Method SpawnAddsThreaded

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

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 1

UnstoppableFunction · 0.85

Tested by

no test coverage detected