Replace the waitcond and mutex with sema on RBTask

src/engine/bufferscalers/rubberbandtask.cpp

@@ -8,7 +8,7 @@ RubberBandTask::RubberBandTask(
         size_t sampleRate, size_t channels, Options options)
         : RubberBand::RubberBandStretcher(sampleRate, channels, options),
           QRunnable(),
-          m_completed(false),
+          m_completedSema(0),
           m_input(nullptr),
           m_samples(0),
           m_isFinal(false) {
@@ -18,31 +18,25 @@ RubberBandTask::RubberBandTask(
 void RubberBandTask::set(const float* const* input,
         size_t samples,
         bool isFinal) {
-    auto locker = lockMutex(&m_waitLock);
-    m_completed = false;
+    DEBUG_ASSERT(m_completedSema.available() == 0);
     m_input = input;
     m_samples = samples;
     m_isFinal = isFinal;
 }
 
 void RubberBandTask::waitReady() {
-    auto locker = lockMutex(&m_waitLock);
     VERIFY_OR_DEBUG_ASSERT(m_input && m_samples) {
         return;
     };
-    while (!m_completed) {
-        m_waitCondition.wait(&m_waitLock);
-    }
+    m_completedSema.acquire();
 }
 
 void RubberBandTask::run() {
-    auto locker = lockMutex(&m_waitLock);
-    VERIFY_OR_DEBUG_ASSERT(!m_completed && m_input && m_samples) {
+    VERIFY_OR_DEBUG_ASSERT(m_completedSema.available() == 0 && m_input && m_samples) {
         return;
     };
     process(m_input,
             m_samples,
             m_isFinal);
-    m_completed = true;
-    m_waitCondition.wakeOne();
+    m_completedSema.release();
 }

src/engine/bufferscalers/rubberbandtask.h

@@ -2,9 +2,8 @@
 
 #include <rubberband/RubberBandStretcher.h>
 
-#include <QMutex>
 #include <QRunnable>
-#include <QWaitCondition>
+#include <QSemaphore>
 #include <atomic>
 
 #include "audio/types.h"
@@ -33,11 +32,8 @@ class RubberBandTask : public RubberBandStretcher, public QRunnable {
     void run();
 
   private:
-    // Used to schedule the thread
-    QMutex m_waitLock;
-    QWaitCondition m_waitCondition;
     // Whether or not the scheduled job as completed
-    bool m_completed;
+    QSemaphore m_completedSema;
 
     const float* const* m_input;
     size_t m_samples;