Function Producer

engine/dlib/src/test/test_condition_variable.cpp:34–53

static const int MAX = 15000;

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

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

        while (!a->m_Buffer.Full() && i < MAX) {
            a->m_Buffer.Push(i);
            i++;
        }
        dmConditionVariable::Signal(a->m_More);
        dmMutex::Unlock(a->m_Mutex);
    }
}

static void Consumer(void* arg)
{