Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 8dae4a80 authored by Wonsik Kim's avatar Wonsik Kim Committed by Android (Google) Code Review
Browse files

Merge "BLASTBufferQueue: fix AsyncWorker race condition" into sc-dev

parents b1f5ee4a 567533ec
Loading
Loading
Loading
Loading
+1 −1
Original line number Original line Diff line number Diff line
@@ -666,12 +666,12 @@ private:
    void run() {
    void run() {
        std::unique_lock<std::mutex> lock(mMutex);
        std::unique_lock<std::mutex> lock(mMutex);
        while (!mDone) {
        while (!mDone) {
            mCv.wait(lock);
            while (!mRunnables.empty()) {
            while (!mRunnables.empty()) {
                std::function<void()> runnable = mRunnables.front();
                std::function<void()> runnable = mRunnables.front();
                mRunnables.pop_front();
                mRunnables.pop_front();
                runnable();
                runnable();
            }
            }
            mCv.wait(lock);
        }
        }
    }
    }