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

Method SpawnTasks

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

Source from the content-addressed store, hash-verified

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