Struct SharedAtomicBool 

pub struct SharedAtomicBool { /* private fields */ }

Implementations

impl SharedAtomicBool

pub fn create( path: impl AsRef<Path>, init: bool, ) -> Result<Self, SharedAtomicError>

pub fn open(path: impl AsRef<Path>) -> Result<Self, SharedAtomicError>

pub fn load(&self, ord: Ordering) -> bool

pub fn store(&self, v: bool, ord: Ordering)

pub fn swap(&self, v: bool, ord: Ordering) -> bool

pub fn flush(&self) -> Result<(), SharedAtomicError>

pub fn flush_async(&self) -> Result<(), SharedAtomicError>

Non-blocking flush: schedules a writeback via the OS. Note: Windows is only partially async (sync to page cache, not to disk).

Trait Implementations

impl AdaptiveInstance for SharedAtomicBool

fn header(&self) -> &HandshakeHeader

fn ring(&self) -> &ObservationRing

fn make_policy(&self) -> Box<dyn Policy>

fn apply_migration(&self, new_tag: u32)

Called by the sidecar when the policy returns a new strategy tag. Default implementation: just set the tag on the header. Primitives that need heavier migration (data-layout swap) override this to perform the swap before (or after) updating the tag.

impl Send for SharedAtomicBool

impl Sync for SharedAtomicBool