Home
last modified time | relevance | path

Searched defs:AtomicUsize (Results 1 – 18 of 18) sorted by relevance

/external/rust/crates/tokio/src/loom/std/
Datomic_usize.rs6 pub(crate) struct AtomicUsize { struct
7 inner: UnsafeCell<std::sync::atomic::AtomicUsize>, argument
10 unsafe impl Send for AtomicUsize {} implementation
11 unsafe impl Sync for AtomicUsize {} implementation
13 impl AtomicUsize { impl
14 pub(crate) const fn new(val: usize) -> AtomicUsize { in new()
35 impl ops::Deref for AtomicUsize { implementation
45 impl ops::DerefMut for AtomicUsize { implementation
52 impl fmt::Debug for AtomicUsize { implementation
/external/rust/crates/parking_lot_core/src/thread_parker/windows/
Dwaitaddress.rs53 pub fn prepare_park(&'static self, key: &AtomicUsize) { in prepare_park()
63 pub fn park(&'static self, key: &AtomicUsize) { in park()
71 pub fn park_until(&'static self, key: &AtomicUsize, timeout: Instant) -> bool { in park_until()
109 fn wait_on_address(&'static self, key: &AtomicUsize, timeout: u32) -> BOOL { in wait_on_address()
Dkeyed_event.rs95 pub fn prepare_park(&'static self, key: &AtomicUsize) { in prepare_park()
105 pub unsafe fn park(&'static self, key: &AtomicUsize) { in park()
111 pub unsafe fn park_until(&'static self, key: &AtomicUsize, timeout: Instant) -> bool { in park_until()
/external/rust/crates/tokio/src/runtime/scheduler/multi_thread/
Didle.rs154 fn load(cell: &AtomicUsize, ordering: Ordering) -> State { in load()
158 fn unpark_one(cell: &AtomicUsize, num_searching: usize) { in unpark_one()
162 fn inc_num_searching(cell: &AtomicUsize, ordering: Ordering) { in inc_num_searching()
175 fn dec_num_unparked(cell: &AtomicUsize, is_searching: bool) -> bool { in dec_num_unparked()
/external/rust/crates/parking_lot/src/
Delision.rs39 impl AtomicElisionExt for AtomicUsize { implementation
54 impl AtomicElisionExt for AtomicUsize { implementation
/external/rust/crates/rayon-core/src/scope/
Dtest.rs52 fn divide_and_conquer<'scope>(scope: &Scope<'scope>, counter: &'scope AtomicUsize, size: usize) { in divide_and_conquer()
62 fn divide_and_conquer_seq(counter: &AtomicUsize, size: usize) { in divide_and_conquer_seq()
498 fn increment<'slice, 'counter>(counters: &'slice [&'counter AtomicUsize]) { in mixed_lifetime_scope()
516 fn increment<'slice, 'counter>(counters: &'slice [&'counter AtomicUsize]) { in mixed_lifetime_scope_fifo()
/external/rust/crates/crossbeam-epoch/examples/
Dsanitize.rs10 fn worker(a: Arc<Atomic<AtomicUsize>>, handle: LocalHandle) -> usize { in worker()
/external/rust/crates/tokio/src/sync/
Dnotify.rs295 fn atomic_inc_num_notify_waiters_calls(data: &AtomicUsize) { in atomic_inc_num_notify_waiters_calls()
573 fn notify_locked(waiters: &mut WaitList, state: &AtomicUsize, curr: usize) -> Option<Waker> { in notify_locked()
Doneshot.rs1366 fn load(cell: &AtomicUsize, order: Ordering) -> State { in load()
/external/rust/crates/log/src/
Dlib.rs356 struct AtomicUsize { struct
361 impl AtomicUsize { implementation
362 const fn new(v: usize) -> AtomicUsize { in new()
393 unsafe impl Sync for AtomicUsize {} implementation
/external/rust/crates/syn/tests/
Dtest_round_trip.rs76 fn test(path: &Path, failed: &AtomicUsize, abort_after: usize) { in test()
/external/rust/crates/parking_lot_core/src/
Dword_lock.rs292 fn fence_acquire(a: &AtomicUsize) { in fence_acquire()
/external/rust/crates/tokio-util/src/task/
Dspawn_pinned.rs393 task_count: Arc<AtomicUsize>, in run()
/external/crosvm/audio_util/src/
Dfile_streams.rs72 offset: Arc<AtomicUsize>, in new()
/external/rust/crates/thread_local/src/
Dlib.rs443 let total = unsafe { *(&thread_local.values as *const AtomicUsize as *const usize) }; in size_hint_frozen() constant
/external/rust/crates/spin/src/
Drwlock.rs788 atomic: &AtomicUsize, in compare_exchange()
/external/rust/crates/arbitrary/src/
Dlib.rs413 impl<'a> Arbitrary<'a> for AtomicUsize { implementation
/external/rust/crates/rayon/src/iter/
Dtest.rs1622 fn divide_and_conquer<'scope>(scope: &Scope<'scope>, counter: &'scope AtomicUsize, size: usize) { in divide_and_conquer()