Method ThreadTasks

core/base/AsyncTaskPool.h:117–140

    public:
        ThreadTasks() : _stop(false)
        {
            _thread = std::thread([this] {
                for (;;)
                {
                    std::function<void()> task;
                    AsyncTaskCallBack callback;
                    {
                        std::unique_lock<std::mutex> lock(this->_queueMutex);
                        this->_condition.wait(lock, [this] { return this->_stop || !this->_tasks.empty(); });
                        if (this->_stop && this->_tasks.empty())
                            return;
                        task     = std::move(this->_tasks.front());
                        callback = std::move(this->_taskCallBacks.front());
                        this->_tasks.pop();
                        this->_taskCallBacks.pop();
                    }

                    task();
                    Director::getInstance()->getScheduler()->runOnAxmolThread(
                        std::bind(callback.callback, callback.callbackParam));
                }
            });
        }
        ~ThreadTasks()
        {
            {