ThreadFunc() [1/2]

void Spices::VulkanCmdThreadPool::ThreadFunc

(

Thread< VkCommandBuffer > *

thread

)

Thread Function.

Parameters

[in]

thread

Thread Entity.

Name thread.

Exit.

Try recovery unused threads.

Rink First, Thread Tasks.

Rink Second, Pool Tasks.

execute task.

Name thread.

Exit.

Try recovery unused threads.

Rink First, Thread Tasks.

Rink Second, Pool Tasks.

execute task.

Definition at line 69 of file VulkanCmdThreadPool.cpp.

    {
        SPICES_PROFILE_ZONE;
 
        std::stringstream ss;
        ss << m_PoolName << thread->GetId();
 
        ThreadLibrary::SetThreadName(ss.str());
 
        auto lastTime = std::chrono::high_resolution_clock::now();
 
        for (;;)
        {
            Task task;
            {
                std::unique_lock<std::mutex> lock(m_Mutex);
 
                while ((m_Tasks.load() == 0 && thread->GetThreadTasksCount() == 0) || m_IsSuspend)
                {
                    if (!m_IsPoolRunning)
                    {
                        m_Threads.erase(thread->GetId());
                        --m_IdleThreadSize;
                        m_ExitCond.notify_all();
                        return;
                    }
 
                    if (m_PoolMode == PoolMode::MODE_CACHED)
                    {
                        if (m_NotEmpty.wait_for(lock, std::chrono::seconds(1)) == std::cv_status::timeout)
                        {
                            auto now = std::chrono::high_resolution_clock::now();
                            auto dur = std::chrono::duration_cast<std::chrono::seconds>(now - lastTime);
 
                            if (dur.count() >= m_ThreadIdleTimeOut && m_Threads.size() > m_InitThreadSize)
                            {
                                m_Threads.erase(thread->GetId());
                                --m_IdleThreadSize;
                                --m_NThreads;
                                return;
                            }
                        }
                    }
                    else
                    {
                        m_NotEmpty.wait(lock);
                    }
                }
 
                task = thread->RequireTask();
 
                if (!task)
                {
                    task = m_TaskQueue.front();
                    m_TaskQueue.pop();
                    thread->SetThreadInTask(true);
                    --m_Tasks;
                }
 
                --m_IdleThreadSize;
            }
 
            if (m_Tasks > 0)
            {
                m_NotEmpty.notify_all();
            }
 
            if (task != nullptr)
            {
                VkCommandBuffer cmdBuffer = CreateParallelCommandBuffers(thread->GetId());
                task(cmdBuffer);
                thread->SetThreadInTask(false);
                ++m_IdleThreadSize;
                m_IdleCond.notify_all();
            }
            else
            {
                thread->SetThreadInTask(false);
                ++m_IdleThreadSize;
                m_IdleCond.notify_all();
            }
 
            lastTime = std::chrono::high_resolution_clock::now();
        }
    }

References Spices::ThreadLibrary::SetThreadName().