asyncobserver.h

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
 
#pragma once
 
// Nap includes
#include <utility/dllexport.h>
 
// Std includes
#include <thread>
#include <condition_variable>
 
 
namespace nap
{
    namespace audio
    {
        
        class NAPAPI AsyncObserver
        {
        public:
            AsyncObserver() = default;
            ~AsyncObserver() = default;
            
            void setBarrier(uint32_t numberOfNotifications = 1);
            
            void notifyBarrier();
            
            void waitForNotifications();
            
            void notifyOne();
            
            void notifyAll();
            
        private:
            std::condition_variable mCondition;
            std::mutex mMutex;
            
            bool mNotified = false;
            uint32_t mNumberOfNotifications = 0;
            uint32_t mNotificationCounter = 0;
        };
        
    }
}