Function Consumer

engine/dlib/src/test/test_condition_variable.cpp:55–75

}

static void Consumer(void* arg)
{
    ThreadArg* a = (ThreadArg*) arg;

    int i = 0;
    while (i < MAX)
    {
        dmMutex::Lock(a->m_Mutex);
        if (a->m_Buffer.Empty() && i < MAX) {
            dmConditionVariable::Wait(a->m_More, a->m_Mutex);
        }

        while (!a->m_Buffer.Empty() && i < MAX) {
            a->m_Sum += a->m_Buffer[0];
            a->m_Buffer.EraseSwap(0);
            i++;
        }
        dmConditionVariable::Signal(a->m_Less);
        dmMutex::Unlock(a->m_Mutex);
    }
}

TEST(dmConditionVariable, ProducerConsumer)
{