Function LoadThread

engine/resource/src/async/load_queue_threaded.cpp:80–129

    }

    static void LoadThread(void* arg)
    {
        Queue* queue     = (Queue*)arg;
        Request* current = 0;
        LoadResult result;
        while (true)
        {
            {
                dmMutex::ScopedLock lk(queue->m_Mutex);
                if (current != 0)
                {
                    // Just finished one (from previous iteration)
                    queue->m_BytesWaiting += current->m_Buffer.Capacity();
                    queue->m_Loaded++;
                    current->m_Result = result;
                    current           = 0;
                }
                if (queue->m_Shutdown)
                {
                    return;
                }

                current = GetNextRequest(queue);
                if (current == 0x0)
                {
                    // Nothing to do, reset any buffers of inactive requests that are not at default capacity
                    for (uint32_t i = 0; i < QUEUE_SLOTS; ++i)
                    {
                        Request* r = &queue->m_Request[i];
                        if (r->m_Buffer.Size() == 0)
                        {
                            if (r->m_Buffer.Capacity() > DEFAULT_CAPACITY)
                            {
                                // Just free the memory here, no need to allocate while holding the mutex
                                r->m_Buffer.SetCapacity(0);
                            }
                        }
                    }
                    dmConditionVariable::Wait(queue->m_WakeupCond, queue->m_Mutex);
                    current = GetNextRequest(queue);
                }
            }

            if (current)
            {
                // We use the temporary result object here to fill in the data so it can be written with the mutex held.
                DoLoadResource(queue->m_Factory, current, &current->m_Buffer, &result);
            }
        }
    }

    HQueue CreateQueue(dmResource::HFactory factory)
    {