Lines Matching refs:self
37 void Run(Thread* self) {
38 LOG(INFO) << "Before barrier 1 " << *self;
40 barrier_->Wait(self);
42 LOG(INFO) << "Before barrier 2 " << *self;
43 barrier_->Wait(self);
45 LOG(INFO) << "After barrier 2 " << *self;
68 Thread* self = Thread::Current();
75 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2, &count3));
77 thread_pool.StartWorkers(self);
78 barrier.Increment(self, num_threads);
85 barrier.Increment(self, num_threads);
90 thread_pool.Wait(self, true, false);
104 void Run(Thread* self) {
108 barrier_->Pass(self);
123 Thread* self = Thread::Current();
130 thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks));
132 thread_pool.StartWorkers(self);
135 barrier.Increment(self, expected_total_tasks);