apollo::lidar::drivers::SyncQueue< T > 模板类 参考

#include <sync_queue.h>

apollo::lidar::drivers::SyncQueue< T > 的协作图:

Public 成员函数
size_t	push (const T &value)
T	pop ()
bool	popWait (T &ret_ele, unsigned int usec=1000000)
void	clear ()

详细描述

template<typename T>
class apollo::lidar::drivers::SyncQueue< T >

在文件 sync_queue.h 第 66 行定义.

成员函数说明

clear()

template<typename T >

void apollo::lidar::drivers::SyncQueue< T >::clear ( )

inline

在文件 sync_queue.h 第 110 行定义.

                        {
        std::queue<T> empty;
        std::lock_guard<std::mutex> lg(mtx_);
        swap(empty, queue_);
    }

pop()

template<typename T >

T apollo::lidar::drivers::SyncQueue< T >::pop ( )

inline

在文件 sync_queue.h 第 84 行定义.

                   {
        T value;
 
        std::lock_guard<std::mutex> lg(mtx_);
        if (!queue_.empty()) {
            value = queue_.front();
            queue_.pop();
        }
 
        return value;
    }

popWait()

template<typename T >

bool apollo::lidar::drivers::SyncQueue< T >::popWait ( T &  ret_ele, unsigned int  usec = 1000000  )

inline

在文件 sync_queue.h 第 96 行定义.

                                                                 {
        {
            std::lock_guard<std::mutex> lg(mtx_);
            if (!queue_.empty()) {
                ret_ele = queue_.front();
                queue_.pop();
                return true;
            }
        }
 
        std::this_thread::sleep_for(std::chrono::microseconds(1000));
        return false;
    }

push()

template<typename T >

size_t apollo::lidar::drivers::SyncQueue< T >::push ( const T &  value )

inline

在文件 sync_queue.h 第 68 行定义.

                                       {
        bool empty = false;
        size_t size = 0;
 
        {
            std::lock_guard<std::mutex> lg(mtx_);
            empty = queue_.empty();
            queue_.push(value);
            size = queue_.size();
        }
 
        if (empty)
            cv_.notify_one();
        return size;
    }

---

该类的文档由以下文件生成:

• modules/drivers/lidar/common/sync_queue.h