Lines Matching refs:n
15 for (int n = 0; n < 10; ++n) { in TEST() local
22 EXPECT_FALSE(cv.WaitFor(&mutex, TimeDelta::FromMicroseconds(n))); in TEST()
25 EXPECT_FALSE(cv.WaitFor(&mutex, TimeDelta::FromMicroseconds(n))); in TEST()
63 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
64 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST()
65 EXPECT_FALSE(threads[n].running_); in TEST()
66 EXPECT_FALSE(threads[n].finished_); in TEST()
67 threads[n].Start(); in TEST()
69 while (!threads[n].running_) { in TEST()
70 threads[n].cv_.Wait(&threads[n].mutex_); in TEST()
74 for (int n = kThreadCount - 1; n >= 0; --n) { in TEST() local
75 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST()
76 EXPECT_TRUE(threads[n].running_); in TEST()
77 EXPECT_FALSE(threads[n].finished_); in TEST()
80 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
81 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST()
82 EXPECT_TRUE(threads[n].running_); in TEST()
83 EXPECT_FALSE(threads[n].finished_); in TEST()
85 threads[n].running_ = false; in TEST()
86 threads[n].cv_.NotifyOne(); in TEST()
89 for (int n = kThreadCount - 1; n >= 0; --n) { in TEST() local
91 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST()
92 while (!threads[n].finished_) { in TEST()
93 threads[n].cv_.Wait(&threads[n].mutex_); in TEST()
95 EXPECT_FALSE(threads[n].running_); in TEST()
96 EXPECT_TRUE(threads[n].finished_); in TEST()
99 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
100 threads[n].Join(); in TEST()
101 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST()
102 EXPECT_FALSE(threads[n].running_); in TEST()
103 EXPECT_TRUE(threads[n].finished_); in TEST()
145 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
146 threads[n].mutex_ = &mutex; in TEST()
147 threads[n].cv_ = &cv; in TEST()
153 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
154 EXPECT_FALSE(threads[n].running_); in TEST()
155 EXPECT_FALSE(threads[n].finished_); in TEST()
156 threads[n].Start(); in TEST()
163 for (int n = kThreadCount - 1; n >= 0; --n) { in TEST() local
164 while (!threads[n].running_) { in TEST()
173 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
174 EXPECT_TRUE(threads[n].running_); in TEST()
175 EXPECT_FALSE(threads[n].finished_); in TEST()
182 for (int n = kThreadCount - 1; n >= 0; --n) { in TEST() local
183 EXPECT_TRUE(threads[n].running_); in TEST()
184 EXPECT_FALSE(threads[n].finished_); in TEST()
186 threads[n].running_ = false; in TEST()
194 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
195 while (!threads[n].finished_) { in TEST()
204 for (int n = kThreadCount - 1; n >= 0; --n) { in TEST() local
205 EXPECT_FALSE(threads[n].running_); in TEST()
206 EXPECT_TRUE(threads[n].finished_); in TEST()
211 for (int n = 0; n < kThreadCount; ++n) { in TEST() local
212 threads[n].Join(); in TEST()
277 for (int n = 0; n < thread_count; ++n) { in TEST() local
278 threads[n] = new LoopIncrementThread(n, &counter, limit, thread_count, in TEST()
283 for (int n = thread_count - 1; n >= 0; --n) { in TEST() local
284 threads[n]->Start(); in TEST()
288 for (int n = 0; n < thread_count; ++n) { in TEST() local
289 threads[n]->Join(); in TEST()
290 delete threads[n]; in TEST()