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

Method SpawnTasks

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

Source from the content-addressed store, hash-verified

101 AddTester(AddTester&&) = default;
102
103 void SpawnTasks(ThreadPool* pool, AddTaskFunc add_func) {
104 for (int i = 0; i < nadds_; ++i) {
105 ASSERT_OK(pool->Spawn([this, add_func, i] { add_func(xs_[i], ys_[i], &outs_[i]); },
106 stop_token_));
107 }
108 }
109
110 void CheckResults() {
111 for (int i = 0; i < nadds_; ++i) {

Callers 3

DoSpawnAddsMethod · 0.80
DoSpawnAddsThreadedMethod · 0.80
TEST_FFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected