Struct width_counters::CounterI32
source · pub struct CounterI32 { /* private fields */ }Expand description
A monotonically increasing atomic counter using AtomicI32 / (core::i32).
Behavior
- The default ordering is Sequentially Consistent.
- The ordering used for atomic operations is customizable for operations ending in
with_ordering. - The choice of ordering intentionally impacts EVERYTHING about how this counter works, including de/serialization, incrementing, jumping, equality comparisons, partial ordering comparisons, etc.
- Total (non-partial) ordering comparisons always use the default ordering.
Other Notes
- PartialEq is implemented such that counters with differing orderings are never equal.
- PartialOrd is implemented such that counters with differing (atomic) orderings produce no (comparison) ordering.
- Unlike the underlying AtomicI32, this will not wrap on overflow.
Implementations§
source§impl CounterI32
impl CounterI32
sourcepub const MAX: i32 = 2_147_483_647i32
pub const MAX: i32 = 2_147_483_647i32
Largest representable value
sourcepub const DEFAULT_ORDERING: Ordering = Ordering::SeqCst
pub const DEFAULT_ORDERING: Ordering = Ordering::SeqCst
Default Atomic ordering
sourcepub const fn new_with_ordering(ordering: Ordering) -> Self
pub const fn new_with_ordering(ordering: Ordering) -> Self
Instantiate with ordering
sourcepub const fn new_from_offset(offset: i32) -> Self
pub const fn new_from_offset(offset: i32) -> Self
Instantiate with offset value
sourcepub const fn new_from_offset_with_ordering(
offset: i32,
ordering: Ordering
) -> Self
pub const fn new_from_offset_with_ordering( offset: i32, ordering: Ordering ) -> Self
Instantiate with offset value and ordering
sourcepub fn get(&self) -> i32
pub fn get(&self) -> i32
Get current value with the default ordering
use width_counters::{CounterI32 as C };
use i32 as U;
let c = C::new();
assert_eq!(c.get(), 0, "get returns initial value");
c.inc();
c.inc();
c.inc();
assert_eq!(c.get(), 3, "get returns post-increment value");sourcepub fn get_with_ordering(&self, ordering: Ordering) -> i32
pub fn get_with_ordering(&self, ordering: Ordering) -> i32
Get current value with a specific ordering
sourcepub fn inc(&self)
pub fn inc(&self)
Increment by one
use width_counters::{CounterI32 as C };
use i32 as U;
let c = C::new();
let m = 20;
(0..m).for_each(|_| { c.inc(); });
assert_eq!(c.get(), 20, "counter must count number of times given as per sequential ordering");
let d = C::new_from_offset(U::MAX);
d.inc();
d.inc();
assert_eq!(d.get(), U::MAX, "counter must stop at maximum");sourcepub fn inc_with_ordering(&self, ordering: Ordering)
pub fn inc_with_ordering(&self, ordering: Ordering)
Increment by one with ordering
sourcepub fn jump(&self, amount: i32)
pub fn jump(&self, amount: i32)
Jump by specified amount
use width_counters::{CounterI32 as C };
use i32 as U;
let c = C::default();
let m = 20;
(0..m).for_each(|_| { c.jump(2); });
assert_eq!(c.get(), 20*2, "counter must jump by specified amount");sourcepub fn jump_with_ordering(&self, amount: i32, ordering: Ordering)
pub fn jump_with_ordering(&self, amount: i32, ordering: Ordering)
Jump by specified amount with ordering
use width_counters::{CounterI32 as C };
use i32 as U;
let c = C::new();
let m: U = 20;
(0..m).for_each(|_| { c.jump(2); });
assert_eq!(c.get(), 40, "counter must jump by specified amount");
let d = C::new_from_offset(U::MAX - m);
d.jump(m/3);
d.jump(m/3);
d.jump(m/2);
assert_eq!(d.get(), U::MAX, "counter must stop at maximum");Trait Implementations§
source§impl AsRef<Ordering> for CounterI32
impl AsRef<Ordering> for CounterI32
source§impl Clone for CounterI32
impl Clone for CounterI32
source§impl Debug for CounterI32
impl Debug for CounterI32
source§impl Default for CounterI32
impl Default for CounterI32
source§impl Display for CounterI32
impl Display for CounterI32
source§impl From<&CounterI32> for i32
impl From<&CounterI32> for i32
source§fn from(counter: &CounterI32) -> Self
fn from(counter: &CounterI32) -> Self
Converts to this type from the input type.
source§impl From<i32> for CounterI32
impl From<i32> for CounterI32
source§impl Hash for CounterI32
impl Hash for CounterI32
source§impl Ord for CounterI32
impl Ord for CounterI32
source§impl PartialEq<CounterI32> for CounterI32
impl PartialEq<CounterI32> for CounterI32
PartialEq is only equal when orderings are equal
use width_counters::{CounterI32 as C };
use core::sync::atomic::Ordering;
let a = C::new_from_offset_with_ordering(33, Ordering::Relaxed);
let b = C::new_from_offset_with_ordering(33, Ordering::Relaxed);
assert_eq!(a, b, "counters must be equal when counts and orderings are equal");
assert_eq!(a, b, "counters must be equal when counts and orderings are equal");
let m = 20;
(0..m).for_each(|_| { a.inc(); b.inc(); });
assert_eq!(a, b, "counters must be equal after counting same amount");
assert_eq!(a, b, "counters must be equal after counting same amount");
a.inc();
assert_ne!(a, b, "counters must not be equal after counting different amounts");
let c = C::new_from_offset_with_ordering(44, Ordering::Relaxed);
let d = C::new_from_offset_with_ordering(44, Ordering::Release);
assert_ne!(c, d, "ordering-inequal counters must not be equal with same count");source§impl PartialOrd<CounterI32> for CounterI32
impl PartialOrd<CounterI32> for CounterI32
PartialOrd only produces cmp ordering when atomic orderings are equal
use width_counters::{CounterI32 as C };
use core::sync::atomic::Ordering;
let a = C::new_from_offset_with_ordering(32, Ordering::Relaxed);
let b = C::new_from_offset_with_ordering(33, Ordering::Relaxed);
assert!(a < b, "same-cmp::ordering counters must be ordered by when counts");
assert!(b > a, "same-cmp::ordering counters must be ordered by when counts");
let m = 20;
(0..m).for_each(|_| { a.inc(); b.inc(); });
assert!(a < b, "cmp::ordering preserved after counting same amount");
assert!(b > a, "cmp::ordering preserved after counting same amount");1.0.0 · source§fn le(&self, other: &Rhs) -> bool
fn le(&self, other: &Rhs) -> bool
This method tests less than or equal to (for
self and other) and is used by the <=
operator. Read moreimpl Eq for CounterI32
Auto Trait Implementations§
impl RefUnwindSafe for CounterI32
impl Send for CounterI32
impl Sync for CounterI32
impl Unpin for CounterI32
impl UnwindSafe for CounterI32
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more