Universal thread-safe message (callback) queue implementation. More...

Public Types#
using	Message = std::function<void(Args...)>

Public Member Functions#
void	enqueue (Message message)
	Add message to the queue to process in processMessages().

void	processMessages (Args... args)
	Process messages submitted by enqueue method.

Mutex &	sync () noexcept

ADeque< Message > &	messages () noexcept

const Mutex &	sync () const noexcept

const ADeque< Message > &	messages () const noexcept

Detailed Description

template<typename Mutex = AMutex, typename... Args>
class AMessageQueue< Mutex, Args >

Thread-safe message queue. The implementation supports enqueueing new messages inside the callbacks.

Public Types#