Convolver.cpp

Go to the documentation of this file.

namespace krotos
{
    class ConvolverBackgroundThread : public Thread
    {
      public:
        explicit ConvolverBackgroundThread(Convolver& convolver)
            : Thread("ConvolverBackgroundThread"), m_convolver(convolver)
        {
            startThread(); // Use a priority higher than the priority of normal threads
        }
 
        virtual ~ConvolverBackgroundThread()
        {
            signalThreadShouldExit();
            notify();
            stopThread(1000);
        }
 
        virtual void run()
        {
            while (!threadShouldExit())
            {
                wait(-1);
                if (threadShouldExit())
                {
                    return;
                }
                m_convolver.doBackgroundProcessing();
                m_convolver.m_backgroundProcessingFinished.store(1);
                m_convolver.m_backgroundProcessingFinishedEvent.signal();
            }
        }
 
      private:
        Convolver& m_convolver;
 
        JUCE_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(ConvolverBackgroundThread)
    };
 
    Convolver::Convolver() : m_backgroundProcessingFinished(1), m_backgroundProcessingFinishedEvent(true)
    {
        m_thread.reset(new ConvolverBackgroundThread(*this));
        m_backgroundProcessingFinishedEvent.signal();
    }
 
    Convolver::~Convolver() { m_thread = nullptr; }
 
    void Convolver::startBackgroundProcessing()
    {
        m_backgroundProcessingFinished.store(0);
        m_backgroundProcessingFinishedEvent.reset();
        m_thread->notify();
    }
 
    void Convolver::waitForBackgroundProcessing() { m_backgroundProcessingFinishedEvent.wait(); }
} // namespace krotos