#[derive(Debug)]
pub struct AtomicBoolSpinLock(AtomicBool);
impl Default for AtomicBoolSpinLock
{
#[inline(always)]
fn default() -> Self
{
AtomicBoolSpinLock(AtomicBool::new(Self::Unlocked))
}
}
impl SpinLock for AtomicBoolSpinLock
{
#[inline(always)]
fn acquire_spin_lock(&self)
{
while !self.try_to_acquire_spin_lock()
{
while self.is_locked()
{
spin_loop_hint();
}
}
}
#[inline(always)]
fn try_to_acquire_spin_lock(&self) -> bool
{
let previously_was = self.0.fetch_or(Self::Locked, Acquire);
previously_was == Self::Unlocked
}
#[inline(always)]
fn unlock_spin_lock(&self)
{
debug_assert!(self.is_locked(), "Does not have spin lock");
self.forcibly_unlock_spin_lock()
}
#[inline(always)]
fn is_locked(&self) -> bool
{
self.0.load(Relaxed) == Self::Locked
}
#[inline(always)]
fn is_unlocked(&self) -> bool
{
self.0.load(Relaxed) == Self::Unlocked
}
#[inline(always)]
fn forcibly_unlock_spin_lock(&self)
{
self.0.store(Self::Unlocked, Release)
}
}
#[allow(non_upper_case_globals)]
impl AtomicBoolSpinLock
{
const Unlocked: bool = false;
const Locked: bool = true;
}