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.rs67 pub fn prepare_park(&'static self, key: &AtomicUsize) { in prepare_park()
77 pub fn park(&'static self, key: &AtomicUsize) { in park()
85 pub fn park_until(&'static self, key: &AtomicUsize, timeout: Instant) -> bool { in park_until()
123 fn wait_on_address(&'static self, key: &AtomicUsize, timeout: DWORD) -> BOOL { in wait_on_address()
Dkeyed_event.rs112 pub fn prepare_park(&'static self, key: &AtomicUsize) { in prepare_park()
122 pub unsafe fn park(&'static self, key: &AtomicUsize) { in park()
128 pub unsafe fn park_until(&'static self, key: &AtomicUsize, timeout: Instant) -> bool { in park_until()
/external/rust/crates/tokio/src/runtime/thread_pool/
Didle.rs150 fn load(cell: &AtomicUsize, ordering: Ordering) -> State { in load()
154 fn unpark_one(cell: &AtomicUsize) { in unpark_one()
158 fn inc_num_searching(cell: &AtomicUsize, ordering: Ordering) { in inc_num_searching()
171 fn dec_num_unparked(cell: &AtomicUsize, is_searching: bool) -> bool { in dec_num_unparked()
/external/rust/crates/parking_lot/src/
Delision.rs37 impl AtomicElisionExt for AtomicUsize { implementation
52 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()
483 fn increment<'slice, 'counter>(counters: &'slice [&'counter AtomicUsize]) { in mixed_lifetime_scope()
501 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/once_cell/src/
Dimp_std.rs150 fn initialize_inner(my_state_and_queue: &AtomicUsize, init: &mut dyn FnMut() -> bool) -> bool { in initialize_inner()
187 fn wait(state_and_queue: &AtomicUsize, mut current_state: usize) { in wait()
/external/rust/crates/syn/tests/
Dtest_round_trip.rs70 fn test(path: &Path, failed: &AtomicUsize, abort_after: usize) { in test()
/external/crosvm/devices/src/virtio/
Dinterrupt.rs86 interrupt_status: Arc<AtomicUsize>, in new()
/external/rust/crates/log/src/
Dlib.rs308 struct AtomicUsize { struct
313 impl AtomicUsize { impl
314 const fn new(v: usize) -> AtomicUsize { in new()
345 unsafe impl Sync for AtomicUsize {} implementation
/external/rust/crates/tokio/src/sync/
Dnotify.rs463 fn notify_locked(waiters: &mut WaitList, state: &AtomicUsize, curr: usize) -> Option<Waker> { in notify_locked()
Doneshot.rs905 fn load(cell: &AtomicUsize, order: Ordering) -> State { in load()
/external/rust/crates/tokio/src/sync/mpsc/
Dchan.rs336 impl Semaphore for AtomicUsize { implementation
/external/rust/crates/thread_local/src/
Dlib.rs439 let total = unsafe { *(&thread_local.values as *const AtomicUsize as *const usize) }; in size_hint_frozen() constant
/external/rust/crates/spin/src/
Drw_lock.rs709 atomic: &AtomicUsize, in compare_exchange()
/external/rust/crates/arbitrary/src/
Dlib.rs390 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()