Method ThreadFunc

layers/state_tracker/queue_state.cpp:330–363

}

void vvl::Queue::ThreadFunc() {
    VVL_TracySetThreadName(__FUNCTION__);

    QueueSubmission* submission = nullptr;

    // Roll this queue forward, one submission at a time.
    while (true) {
        submission = NextSubmission();
        if (submission == nullptr) {
            break;
        }
        Retire(*submission);
        // wake up anyone waiting for this submission to be retired
        {
            std::shared_ptr<Fence> fence;
            std::promise<void> completed;
            {
                auto guard = Lock();
                fence = std::move(submission->fence);
                completed = std::move(submission->completed);
                submissions_.pop_front();
            }

            // Retire the fence after removing the submission from the queue (submissions_.pop_front).
            // This ensures the completed QueueSubmission is not visible after vkWaitForFences
            if (fence) {
                fence->Retire();
            }

            // Unblock waiting QueueWaitIdle/DeviceWaitIdle
            completed.set_value();
        }
    }
}