Lines Matching defs:self
36 virtual void Run(Thread* self) OVERRIDE {
38 task_processor_->AddTask(self,
55 virtual void Run(Thread* self) OVERRIDE {
56 task_processor_->RunAllTasks(self);
67 Thread* const self = Thread::Current();
72 task_processor.AddTask(self, new RecursiveTask(&task_processor, &counter, kRecursion));
73 task_processor.Start(self);
75 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running));
76 thread_pool.StartWorkers(self);
83 task_processor.Stop(self);
84 thread_pool.Wait(self, true, false);
92 // Self interrupt before any of the other tasks run, but since we added them we should keep on
94 task_processor.Stop(self);
95 task_processor.AddTask(self, new RecursiveTask(&task_processor, &counter, kRecursion));
96 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running));
97 thread_pool.StartWorkers(self);
98 thread_pool.Wait(self, true, false);
121 Thread* const self = Thread::Current();
123 task_processor.Stop(self);
134 task_processor.AddTask(self, task);
139 thread_pool.AddTask(self, new WorkUntilDoneTask(&task_processor, &done_running));
141 thread_pool.StartWorkers(self);
142 thread_pool.Wait(self, true, false);
