最佳答案
C + + 11个线程安全队列
我正在从事的一个项目使用多个线程来处理一组文件。每个线程都可以将文件添加到要处理的文件列表中，因此我将一个线程安全队列放在一起(我认为是这样的)。相关部分如下:
// qMutex is a std::mutex intended to guard the queue
// populatedNotifier is a std::condition_variable intended to
// notify waiting threads of a new item in the queue
void FileQueue::enqueue(std::string&& filename)
{
std::lock_guard<std::mutex> lock(qMutex);
q.push(std::move(filename));
// Notify anyone waiting for additional files that more have arrived
populatedNotifier.notify_one();
}
std::string FileQueue::dequeue(const std::chrono::milliseconds& timeout)
{
std::unique_lock<std::mutex> lock(qMutex);
if (q.empty()) {
if (populatedNotifier.wait_for(lock, timeout) == std::cv_status::no_timeout) {
std::string ret = q.front();
q.pop();
return ret;
}
else {
return std::string();
}
}
else {
std::string ret = q.front();
q.pop();
return ret;
}
}
但是，我偶尔会在 if (...wait_for(lock, timeout) == std::cv_status::no_timeout) { }块内部进行分段，而在 gdb 中的检查表明，由于队列为空，所以发生了分段错误。这怎么可能？我的理解是，wait_for只有在接到通知时才返回 cv_status::no_timeout，而且只有在 FileQueue::enqueue刚刚将一个新项目推入队列之后才会返回 cv_status::no_timeout。
