spsc_sema::LightweightSemaphore Class Reference

Public Types
typedef std::make_signed< std::size_t >::type	ssize_t

Public Member Functions
AE_NO_TSAN	LightweightSemaphore (ssize_t initialCount=0)
bool	tryWait () AE_NO_TSAN
void	wait () AE_NO_TSAN
bool	wait (std::int64_t timeout_usecs) AE_NO_TSAN
void	signal (ssize_t count=1) AE_NO_TSAN
ssize_t	availableApprox () const AE_NO_TSAN

Private Member Functions
bool	waitWithPartialSpinning (std::int64_t timeout_usecs=-1) AE_NO_TSAN

Private Attributes
weak_atomic< ssize_t >	m_count
Semaphore	m_sema

Member Typedef Documentation

ssize_t

typedef std::make_signed<std::size_t>::type spsc_sema::LightweightSemaphore::ssize_t

Constructor & Destructor Documentation

LightweightSemaphore()

AE_NO_TSAN spsc_sema::LightweightSemaphore::LightweightSemaphore

(

ssize_t

initialCount = 0

)

Member Function Documentation

availableApprox()

ssize_t spsc_sema::LightweightSemaphore::availableApprox

(

)

const

References weak_atomic< T >::load(), and m_count.

signal()

void spsc_sema::LightweightSemaphore::signal

(

ssize_t

count = 1

)

References weak_atomic< T >::fetch_add_release(), m_count, and m_sema.

tryWait()

bool spsc_sema::LightweightSemaphore::tryWait

(

)

References weak_atomic< T >::fetch_add_acquire(), weak_atomic< T >::load(), and m_count.

Referenced by wait().

wait() [1/2]

void spsc_sema::LightweightSemaphore::wait

(

)

References tryWait(), and waitWithPartialSpinning().

wait() [2/2]

bool spsc_sema::LightweightSemaphore::wait

(

std::int64_t

timeout_usecs

)

References tryWait(), and waitWithPartialSpinning().

waitWithPartialSpinning()

bool spsc_sema::LightweightSemaphore::waitWithPartialSpinning ( std::int64_t  timeout_usecs = -1 )

private

References compiler_fence(), weak_atomic< T >::fetch_add_acquire(), weak_atomic< T >::fetch_add_release(), weak_atomic< T >::load(), m_count, m_sema, and memory_order_acquire.

Referenced by wait().

Member Data Documentation

m_count

weak_atomic<ssize_t> spsc_sema::LightweightSemaphore::m_count

private

Referenced by availableApprox(), signal(), tryWait(), and waitWithPartialSpinning().

m_sema

Semaphore spsc_sema::LightweightSemaphore::m_sema

private

Referenced by signal(), and waitWithPartialSpinning().