Struct aeron_rs::concurrent::atomic_counter::AtomicCounter

pub struct AtomicCounter { /* fields omitted */ }

Methods

impl AtomicCounter

pub fn new(buffer: AtomicBuffer, counter_id: i32) -> Self

pub fn new_opt(
    buffer: AtomicBuffer,
    counter_id: i32,
    counters_mgr: Arc<Mutex<CountersManager>>
) -> Self

pub fn id(&self) -> i32

pub fn increment(&self)

pub fn increment_ordered(&self)

pub fn set(&self, value: i64)

pub fn set_ordered(&self, value: i64)

pub fn set_weak(&self, value: i64)

pub fn get_and_add(&self, value: i64) -> i64

pub fn get_and_add_ordered(&self, increment: i64) -> i64

pub fn get_and_set(&self, value: i64) -> i64

pub fn compare_and_set(&self, expected_value: i64, update_value: i64) -> bool

pub fn get(&self) -> i64

pub fn get_weak(&self) -> i64

Trait Implementations

impl Drop for AtomicCounter

fn drop(&mut self)

Executes the destructor for this type.