SubmitPoolTask()

template<typename Func , typename ... Args>

auto Spices::VulkanCmdThreadPool::SubmitPoolTask ( Func && func, Args &&... args ) -> std::future<decltype(func(nullptr, std::forward<Args>(args)...))>

inline

Submit a part commands task to task queue, and wait for a idle thread to execute it.

Template Parameters

Func	Task Function.
Args	Task Parameters.

pack task as a lambda and submit it to queue.

Expand threads container if in MODE_CACHED.

Definition at line 88 of file VulkanCmdThreadPool.h.

    {
        SPICES_PROFILE_ZONE;
 
        using RType = decltype(func(nullptr, args...));
 
        auto task = std::make_shared<std::packaged_task<RType(VkCommandBuffer)>>(std::bind(std::forward<Func>(func), std::placeholders::_1, std::forward<Args>(args)...));
        std::future<decltype(func(nullptr, std::forward<Args>(args)...))> result = task->get_future();
        
        {
            std::unique_lock<std::mutex> lock(m_Mutex);
 
            m_TaskQueue.emplace([task](VkCommandBuffer cmdBuffer) { (*task)(cmdBuffer); });
            ++m_Tasks;
 
            if (m_PoolMode == PoolMode::MODE_CACHED && m_TaskQueue.size() > m_IdleThreadSize && m_Threads.size() < THREAD_MAX_THRESHHOLD)
            {
                for (uint32_t i = 0; i < THREAD_MAX_THRESHHOLD; i++)
                {
                    if (m_Threads.find(i) == m_Threads.end())
                    {
                        auto ptr = std::make_unique<Thread<VkCommandBuffer>>(std::bind(&VulkanCmdThreadPool::ThreadFunc, this, std::placeholders::_1), i);
                        uint32_t threadId = ptr->GetId();
 
                        ptr->Start();
                        m_Threads.emplace(threadId, std::move(ptr));
 
                        ++m_IdleThreadSize;
                        ++m_NThreads;
 
                        break;
                    }
                }
            }
        }
 
        m_NotEmpty.notify_all();
 
        return result;
    }