Method ThreadProc

src/base/taskpool.hpp:77–95

        return NULL;
    }
    void ThreadProc() {
        while (true) {
            Task task;
            {
                std::unique_lock<std::mutex> lock(mutex_);
                while (queue_.empty() && !stop_) {
                    work_cv_.wait(lock);
                }
                if (stop_ && queue_.empty()) {
                    break;
                }
                if (!queue_.empty()) {
                    task = queue_.pop();
                }
                queue_cv_.notify_one();
            }
            task();
        }
    }
    bool stop_;
    uint32_t threads_num_;
    ::fedb::base::RingQueue<Task> queue_;