Lines Matching refs:thread
85 Waiter waiter_; // Thread-safe.
103 // Awake immediately after thread start.
105 WaitingThread thread(10 * test::EpsilonTimeout().InMicroseconds());
106 thread.Start();
107 thread.waiter()->Awake(MOJO_RESULT_OK, 1);
108 thread.WaitUntilDone(&result, &context, &elapsed);
114 // Awake before after thread start.
116 WaitingThread thread(10 * test::EpsilonTimeout().InMicroseconds());
117 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2);
118 thread.Start();
119 thread.WaitUntilDone(&result, &context, &elapsed);
125 // Awake some time after thread start.
127 WaitingThread thread(10 * test::EpsilonTimeout().InMicroseconds());
128 thread.Start();
130 thread.waiter()->Awake(1, 3);
131 thread.WaitUntilDone(&result, &context, &elapsed);
138 // Awake some longer time after thread start.
140 WaitingThread thread(10 * test::EpsilonTimeout().InMicroseconds());
141 thread.Start();
143 thread.waiter()->Awake(2, 4);
144 thread.WaitUntilDone(&result, &context, &elapsed);
151 // Don't awake -- time out (on another thread).
153 WaitingThread thread(2 * test::EpsilonTimeout().InMicroseconds());
154 thread.Start();
155 thread.WaitUntilDone(&result, &context, &elapsed);
164 // Awake immediately after thread start.
166 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
167 thread.Start();
168 thread.waiter()->Awake(MOJO_RESULT_OK, 5);
169 thread.WaitUntilDone(&result, &context, &elapsed);
175 // Awake before after thread start.
177 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
178 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6);
179 thread.Start();
180 thread.WaitUntilDone(&result, &context, &elapsed);
186 // Awake some time after thread start.
188 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
189 thread.Start();
191 thread.waiter()->Awake(1, 7);
192 thread.WaitUntilDone(&result, &context, &elapsed);
199 // Awake some longer time after thread start.
201 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
202 thread.Start();
204 thread.waiter()->Awake(2, 8);
205 thread.WaitUntilDone(&result, &context, &elapsed);
253 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
254 thread.Start();
255 thread.waiter()->Awake(MOJO_RESULT_OK, 1);
256 thread.waiter()->Awake(1, 2);
257 thread.WaitUntilDone(&result, &context, &elapsed);
264 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
265 thread.waiter()->Awake(1, 3);
266 thread.Start();
267 thread.waiter()->Awake(MOJO_RESULT_OK, 4);
268 thread.WaitUntilDone(&result, &context, &elapsed);
275 WaitingThread thread(MOJO_DEADLINE_INDEFINITE);
276 thread.Start();
277 thread.waiter()->Awake(10, 5);
279 thread.waiter()->Awake(20, 6);
280 thread.WaitUntilDone(&result, &context, &elapsed);
287 WaitingThread thread(10 * test::EpsilonTimeout().InMicroseconds());
288 thread.Start();
290 thread.waiter()->Awake(MOJO_RESULT_FAILED_PRECONDITION, 7);
292 thread.waiter()->Awake(MOJO_RESULT_OK, 8);
293 thread.WaitUntilDone(&result, &context, &elapsed);
