queue_safe.cpp
#pragma once
#include <iostream>
#include <queue>
#include <string>
#include <mutex>
#include <condition_variable>
#include <chrono>
#include "queue_safe.h"
void SafeQueue::initialize() {
/* initialize a std::queue */
safe_queue = {};
}
std::string SafeQueue::get() {
std::unique_lock<std::mutex> condition_lock(queue_lock);
/* wait 20 seconds */
std::chrono::system_clock::time_point wait = std::chrono::system_clock::now() + std::chrono::system_clock::duration(20);
while (safe_queue.empty()) {
if (ready.wait_until(condition_lock, wait) == std::cv_status::timeout) {
/* timeout was reached, no items left */
std::cout << "no items left in queue..." << std::endl;
}
std::string element = safe_queue.front();
safe_queue.pop();
return element;
}
/* not empty, return an element */
std::string element = safe_queue.front();
safe_queue.pop();
return element;
}
void SafeQueue::put(std::string& element) {
/* does not need to be thread-safe */
safe_queue.push(element);
}
uint8_t SafeQueue::empty() {
std::unique_lock<std::mutex> condition_lock(queue_lock);
if (safe_queue.size() == 0) {
return 1;
}
return 0;
}
字符串
queue_safe.h
#pragma once
#include <string>
#include <mutex>
#include <queue>
#include <condition_variable>
class SafeQueue {
public:
std::condition_variable ready;
std::mutex queue_lock;
std::queue<std::string> safe_queue;
uint8_t empty();
void initialize();
void put(std::string& element);
std::string get();
};
型
这显示了我的代码从队列中安全地获取一个字符串。我想等待最多20秒的元素变得可用,所以我使用了一个条件变量,一个唯一的锁,最后是wait_until
。据我所知,我不需要在push(add)函数周围使用互斥锁。目标:创建一个线程安全的队列,在指定的时间段(这里是20秒)后超时。
问题:这真的是线程安全的吗?我是否需要一个互斥锁/保护来保护push函数,如果是,为什么?
好的,所以1)为了可读性,我需要使用bool而不是unsigned int,2)我需要同步push和pop,3)时间点不是真正的20秒。4)我需要处理'虚假唤醒'
1条答案
按热度按时间kkbh8khc1#
据我所知,我不需要push(add)函数周围的互斥体。
你知道错了。
这真的是线程安全的吗?
号
我是否需要在push函数周围使用互斥锁/保护
是的
为什麽?
因为对容器的无序修改会导致未定义的行为。
std::queue::push
会修改容器。