#include <callback_notifier.h>

Public Member Functions
	CallbackNotifier ()
	Construct a thread-safe notification object. More...

	CallbackNotifier (const CallbackNotifier &)=delete

CallbackNotifier &	operator= (CallbackNotifier const &)=delete

	CallbackNotifier (CallbackNotifier &&o)=delete

CallbackNotifier &	operator= (CallbackNotifier &&o)=delete

void	set ()
	Notify waiting threads that we are done and they can proceed. More...

bool	wait (uint64_t period=0)
	Wait until `set()` has been called or period has elapsed. More...

Detailed Description

A thread-safe notification object.

A thread-safe notification object which can signal release of some shared state while a single thread blocks until the shared state is released.

Constructor & Destructor Documentation

◆ CallbackNotifier()

ucxx::utils::CallbackNotifier::CallbackNotifier ( )

inline

Construct a thread-safe notification object.

Construct a thread-safe notification object which can signal release of some shared state with set() while a single thread blocks on wait() until the shared state is released.

If libc is glibc and the version is older than 2.25, the implementation uses a spinlock otherwise it uses a condition variable.

When C++-20 is the minimum supported version, it should use atomic.wait + notify_one.

Member Function Documentation

◆ set()

void ucxx::utils::CallbackNotifier::set ( )

Notify waiting threads that we are done and they can proceed.

Set the flag to true and notify a single thread blocked by a call to wait(). See also std::condition_variable::notify_one.

◆ wait()

bool ucxx::utils::CallbackNotifier::wait ( uint64_t period = 0 )

Wait until set() has been called or period has elapsed.

Wait until set() has been called, or period (in nanoseconds) has elapsed (only applicable if using glibc 2.25 and higher).

See also std::condition_variable::wait.

Parameters

[in] period maximum period in nanoseconds to wait for or 0 to wait forever.

Returns: true if waiting finished or false if a timeout occurred.

The documentation for this class was generated from the following file: