iframe-proxy | Sunbelt Computer Software

28 lines (21 loc) · 536 Bytes

// Created by wangyaofu on 2018/6/3.
#include "broadcast_queue.h"
BroadcastMsgQueue::BroadcastMsgQueue() {
BroadcastMsgQueue::~BroadcastMsgQueue() {
void BroadcastMsgQueue::addMsg(BroadcastMsg& msg) {
    std::lock_guard<std::mutex> lk(msg_mutex_);
    msg_queue_.push(msg);
int BroadcastMsgQueue::getMsg(BroadcastMsg& broadcastMsg) {
    std::lock_guard<std::mutex> lk(msg_mutex_);
    if (msg_queue_.size() <= 0) {
        return 0;
    broadcastMsg = msg_queue_.front();
    msg_queue_.pop();
    return 1;

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

broadcast_queue.cpp

Latest commit

History

broadcast_queue.cpp

File metadata and controls