Lines Matching refs:Pool

117   ThreadPool Pool;  in TEST_F()  local
119 Pool.async([this, &checked_in] { in TEST_F()
126 Pool.wait(); in TEST_F()
137 ThreadPool Pool; in TEST_F() local
139 Pool.async(TestFunc, std::ref(checked_in), i); in TEST_F()
141 Pool.wait(); in TEST_F()
147 ThreadPool Pool; in TEST_F() local
149 Pool.async([this, &i] { in TEST_F()
153 Pool.async([&i] { ++i; }); in TEST_F()
156 Pool.wait(); in TEST_F()
162 ThreadPool Pool(hardware_concurrency(2)); in TEST_F() local
164 Pool.async([this, &i] { in TEST_F()
169 Pool.async([&i] { ++i; }).get(); in TEST_F()
172 Pool.wait(); in TEST_F()
178 ThreadPool Pool(hardware_concurrency(2)); in TEST_F() local
179 auto F1 = Pool.async([] { return 1; }); in TEST_F()
180 auto F2 = Pool.async([] { return 2; }); in TEST_F()
183 Pool.wait(); in TEST_F()
190 ThreadPool Pool(hardware_concurrency(2)); in TEST_F() local
192 auto F1 = Pool.async(Fn, 1); in TEST_F()
193 auto F2 = Pool.async(Fn, 2); in TEST_F()
196 Pool.wait(); in TEST_F()
206 ThreadPool Pool; in TEST_F() local
208 Pool.async([this, &checked_in] { in TEST_F()
227 ThreadPool Pool(S); in TEST_F() local
229 ThreadPoolTaskGroup Group1(Pool); in TEST_F()
230 ThreadPoolTaskGroup Group2(Pool); in TEST_F()
265 ThreadPool Pool; in TEST_F() local
266 ThreadPoolTaskGroup Group(Pool); in TEST_F()
271 Group.async([this, &Pool, &checked_in1] { in TEST_F()
274 ThreadPoolTaskGroup LocalGroup(Pool); in TEST_F()
300 ThreadPool Pool(S); in TEST_F() local
302 ThreadPoolTaskGroup Group(Pool); in TEST_F()
317 Group.async([this, &Pool] { in TEST_F()
319 ThreadPoolTaskGroup LocalGroup(Pool); in TEST_F()
354 ThreadPool Pool(S); in RunOnAllSockets() local
356 Pool.async([&] { in RunOnAllSockets()