Lines Matching refs:runner
75 auto runner = std::make_unique<TaskRunnerImpl>( in Create() local
77 fake_waiter->SetTaskRunner(runner.get()); in Create()
78 return runner; in Create()
91 TaskRunnerImpl runner(&fake_clock.now); in TEST() local
94 runner.PostTask([&ran_tasks] { ran_tasks += "1"; }); in TEST()
95 runner.RequestStopSoon(); in TEST()
97 runner.RunUntilStopped(); in TEST()
103 TaskRunnerImpl runner(&fake_clock.now); in TEST() local
105 std::thread t([&runner] { runner.RunUntilStopped(); }); in TEST()
111 runner.PostTaskWithDelay(task_one, kDelayTime); in TEST()
114 runner.PostTaskWithDelay(task_two, kDelayTime * 2); in TEST()
125 runner.RequestStopSoon(); in TEST()
131 TaskRunnerImpl runner(&fake_clock.now); in TEST() local
140 runner.PostTask(task_one); in TEST()
141 runner.PostTask(task_two); in TEST()
142 runner.PostTask(task_three); in TEST()
143 runner.PostTask(task_four); in TEST()
144 runner.PostTask(task_five); in TEST()
145 runner.RequestStopSoon(); in TEST()
148 runner.RunUntilStopped(); in TEST()
154 TaskRunnerImpl runner(&fake_clock.now); in TEST() local
157 runner.PostTask([&] { in TEST()
161 runner.PostTask([&] { in TEST()
166 runner.PostTask([&] { in TEST()
168 runner.PostTask([&] { result += " forgotten."; }); in TEST()
173 runner.RequestStopSoon(); in TEST()
177 runner.RunUntilStopped(); in TEST()
186 TaskRunnerImpl runner(&fake_clock.now); in TEST() local
195 runner.PostTask(task); in TEST()
198 runner.RequestStopSoon(); in TEST()
199 runner.RunUntilStopped(); in TEST()
204 TaskRunnerImpl runner(Clock::now); in TEST() local
210 runner.PostTaskWithDelay(delayed_task, milliseconds(10000)); in TEST()
211 runner.PostTask(task); in TEST()
213 runner.RequestStopSoon(); in TEST()
214 runner.RunUntilStopped(); in TEST()
222 std::unique_ptr<TaskRunnerImpl> runner = in TEST() local
226 std::thread t([&runner, &x] { in TEST()
227 runner.get()->RunUntilStopped(); in TEST()
249 std::unique_ptr<TaskRunnerImpl> runner = in TEST() local
253 std::thread t([&runner] { runner.get()->RunUntilStopped(); }); in TEST()
262 runner->PostTask([&x]() { x = 1; }); in TEST()