/art/test/132-daemon-locks-shutdown/src/ |
H A D | Main.java | 28 Thread t = new Thread(new Wait(sync)); 34 private static class Wait implements Runnable { class in class:Main 37 public Wait(Object obj) { method in class:Main.Wait
|
/art/runtime/ |
H A D | signal_set.h | 46 int Wait() { function in class:art::SignalSet
|
H A D | barrier.cc | 37 void Barrier::Wait(Thread* self) { function in class:art::Barrier 58 condition_.Wait(self);
|
H A D | barrier_test.cc | 38 barrier_->Wait(self); 64 Barrier barrier(num_threads + 1); // One extra Wait() in main thread. 77 // Perform one additional Wait(), allowing pool threads to proceed. 78 barrier.Wait(self); 79 // Wait for all the threads to finish. 80 thread_pool.Wait(self, true, false); 124 // Wait for all the tasks to complete using the barrier.
|
H A D | monitor_test.cc | 143 monitor_test_->barrier_->Wait(self); // Let the other thread know we're done. 151 // Now try to Wait on the Monitor. 152 Monitor::Wait(self, monitor_test_->object_.Get(), millis_, 0, true, 162 monitor_test_->complete_barrier_->Wait(self); // Wait for test completion. 189 monitor_test_->barrier_->Wait(self); // Wait for the other thread to set up the monitor. 197 Monitor::Wait(self, monitor_test_->object_.Get(), millis_, 0, true, 207 monitor_test_->complete_barrier_->Wait(self); // Wait fo [all...] |
H A D | thread_pool_test.cc | 70 // Wait for tasks to complete. 71 thread_pool.Wait(self, true, false); 98 thread_pool.Wait(self, false, false); 135 thread_pool.Wait(self, true, false);
|
H A D | barrier.h | 20 // very limited conditions, e.g. if only Pass(), but not Wait() is called. Unlike a standard 22 // Pass() or Wait(), and only then set the count using the Increment() method. Threads at 23 // a Wait() are only awoken if the count reaches zero AFTER the decrement is applied. 24 // This works because, also unlike most latch APIs, there is no way to Wait() without 44 // Wait on the barrier, decrement the count. 45 void Wait(Thread* self) REQUIRES(!lock_); 49 // - has not left the Wait() or Increment() call. 61 // another thread is still in Wait(). See above.
|
H A D | thread_pool.cc | 77 thread_pool_->creation_barier_.Wait(self); 128 // Wait for all of the threads to attach. 129 creation_barier_.Wait(self); 148 // Wait for the threads to finish. 185 task_queue_condition_.Wait(self); 211 void ThreadPool::Wait(Thread* self, bool do_work, bool may_hold_locks) { function in class:art::ThreadPool 219 // Wait until each thread is waiting and the task list is empty. 223 completion_condition_.Wait(self);
|
H A D | object_lock.cc | 37 Monitor::Wait(self_, obj_.Get(), 0, 0, false, kWaiting);
|
H A D | signal_catcher.cc | 80 cond_.Wait(self); 168 int signal_number = signals.Wait();
|
H A D | thread_pool.h | 103 // Wait for all tasks currently on queue to get completed. 104 void Wait(Thread* self, bool do_work, bool may_hold_locks) REQUIRES(!task_queue_lock_);
|
H A D | monitor.h | 86 // NO_THREAD_SAFETY_ANALYSIS for mon->Wait. 87 static void Wait(Thread* self, mirror::Object* obj, int64_t ms, int32_t ns, 231 // Wait on a monitor until timeout, interrupt, or notification. Used for Object.wait() and 250 void Wait(Thread* self, int64_t msec, int32_t nsec, bool interruptShouldThrow, ThreadState why)
|
H A D | thread-inl.h | 203 // Wait while our suspend count is non-zero. 209 Thread::resume_cond_->Wait(this);
|
H A D | monitor.cc | 264 // Wait() requires a deeper call stack to be useful. Otherwise you'll see "Waiting at 360 // Reacquire monitor_lock_ without mutator_lock_ for Wait. 384 monitor_contenders_.Wait(self); // Still contended so wait. 574 void Monitor::Wait(Thread* self, int64_t ms, int32_t ns, function in class:art::Monitor 651 // Wait for a notification or a timeout to occur. 653 self->GetWaitConditionVariable()->Wait(self); 690 AtraceMonitorUnlock(); // End Wait(). 1011 void Monitor::Wait(Thread* self, mirror::Object *obj, int64_t ms, int32_t ns, function in class:art::Monitor 1045 mon->Wait(self, ms, ns, interruptShouldThrow, why);
|
/art/runtime/native/ |
H A D | java_lang_Object.cc | 47 o->Wait(soa.Self()); 53 o->Wait(soa.Self(), ms, ns);
|
H A D | java_lang_Thread.cc | 176 Monitor::Wait(Thread::Current(), lock, ms, ns, true, kSleeping);
|
/art/runtime/gc/ |
H A D | task_processor_test.cc | 78 // Wait until all the tasks are done, but since we didn't interrupt, done_running should be 0. 84 thread_pool.Wait(self, true, false); 98 thread_pool.Wait(self, true, false); 142 thread_pool.Wait(self, true, false);
|
H A D | task_processor.cc | 51 cond_->Wait(self); // Empty queue, wait until we are signalled. 64 // Wait untl we hit the target run time. 121 // Wait and get a task, may be interrupted.
|
/art/test/004-ThreadStress/src/ |
H A D | Main.java | 44 // -wait:X ......... frequency of Wait 203 private final static class Wait extends Operation { class in class:Main 206 public Wait(Object lock) { method in class:Main.Wait 251 frequencyMap.put(new Wait(lock), 0.075); // 15/200 260 frequencyMap.put(new Wait(lock), 0.2); 301 op = new Wait(lock);
|
/art/runtime/jdwp/ |
H A D | jdwp_main.cc | 278 * Wait until the thread finishes basic initialization. 281 state->thread_start_cond_.Wait(self); 298 state->attach_cond_.Wait(self); 358 shutdown_cond_.Wait(self);
|
/art/compiler/ |
H A D | elf_writer_quick.cc | 247 // Wait for the mini-debug-info generation to finish and write it to disk. 250 debug_info_thread_pool_->Wait(self, true, false);
|
/art/runtime/base/ |
H A D | mutex_test.cc | 126 state.cv.Wait(Thread::Current());
|
H A D | mutex.h | 451 // TODO: No thread safety analysis on Wait and TimedWait as they call mutex operations via their 453 void Wait(Thread* self) NO_THREAD_SAFETY_ANALYSIS; 455 // Variant of Wait that should be used with caution. Doesn't validate that no mutexes are held
|
/art/runtime/gc/space/ |
H A D | large_object_space_test.cc | 161 thread_pool.Wait(self, true, false);
|
/art/runtime/jit/ |
H A D | jit.cc | 304 cache->Wait(self, false, false); 696 thread_pool_->Wait(self, false, false);
|