Searched refs:PARKED (Results 1 – 7 of 7) sorted by relevance
| /external/rust/crates/parking_lot_core/src/thread_parker/ |
| D | wasm_atomic.rs | 49 const PARKED: i32 = 1; constant
65 self.parked.store(PARKED, Ordering::Relaxed); in prepare_park()
70 self.parked.load(Ordering::Relaxed) == PARKED in timed_out()
75 while self.parked.load(Ordering::Acquire) == PARKED { in park()
76 let r = wasm32::memory_atomic_wait32(self.ptr(), PARKED, -1); in park()
85 while self.parked.load(Ordering::Acquire) == PARKED { in park_until()
88 let r = wasm32::memory_atomic_wait32(self.ptr(), PARKED, nanos_left); in park_until()
|
| D | redox.rs | 22 const PARKED: i32 = 1; constant
43 self.futex.store(PARKED, Ordering::Relaxed); in prepare_park()
100 PARKED, in futex_wait()
128 let r = futex(self.futex, FUTEX_WAKE, PARKED, 0, ptr::null_mut()); in unpark()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 46 private static final Runnable PARKED = new DoNothingRunnable(); field in InterruptibleTask
94 while (state == INTERRUPTING || state == PARKED) { in run()
103 if (state == PARKED || compareAndSet(INTERRUPTING, PARKED)) { in run()
174 if (prev == PARKED) { in interruptTask()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 46 private static final Runnable PARKED = new DoNothingRunnable(); field in InterruptibleTask
94 while (state == INTERRUPTING || state == PARKED) { in run()
103 if (state == PARKED || compareAndSet(INTERRUPTING, PARKED)) { in run()
174 if (prev == PARKED) { in interruptTask()
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 305 const PARKED: usize = 1; constant
335 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park()
365 NOTIFIED | PARKED => return, in park()
394 PARKED => {} // gotta go wake someone up in unpark()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 31 const PARKED: usize = 1; constant
94 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park()
144 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park_timeout()
164 PARKED => {} // no notification, alas in park_timeout()
178 PARKED => {} // gotta go wake someone up in unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 307 private const val PARKED = -1 in <lambda>() constant
452 if (worker.workerCtl.compareAndSet(PARKED, CLAIMED)) { in <lambda>()
723 workerCtl.value = PARKED // Update value once in <lambda>()
805 if (!workerCtl.compareAndSet(PARKED, TERMINATED)) return in <lambda>()
|