Я понял. Глупая ошибка с моей стороны, я на самом деле не удалял элемент из очереди, я просто читал первый элемент. Я изменил код, и код ниже не работает. Спасибо всем за помощь.
Я пытаюсь реализовать проблему производителя-потребителя, используя boost, который на самом деле является частью более крупного проекта. Я реализовал программу из примеров в Интернете и даже нашел здесь некоторую помощь. Однако в настоящее время мой код просто зависает. Основываясь на одном хорошем совете, я решил использовать буфер Boost ciruclar для хранения моих данных между производителем и потребителем. Там было много похожего кода, и я смог объединить идеи из них и написать что-то свое. Тем не менее, у меня все еще, кажется, та же проблема, что и раньше (моя программа просто зависает). Я думал, что не совершаю той же ошибки, что и раньше..
Мой код приведен ниже, я вынул свой более ранний код, где у меня есть только мой собственный список ссылок.
Заголовок буфера:
#ifndef PCDBUFFER_H
#define PCDBUFFER_H
#include <pcl/io/pcd_io.h>
#include <boost/thread/mutex.hpp>
#include <boost/thread/condition.hpp>
#include <boost/circular_buffer.hpp>
class pcdBuffer
{
public:
pcdBuffer(int buffSize);
void put(int data);
int get();
bool isFull();
bool isEmpty();
int getSize();
int getCapacity();
private:
boost::mutex bmutex;
boost::condition_variable buffEmpty;
boost::condition_variable buffFull;
boost::circular_buffer<int> buffer;
};
#endif
Источник буфера (только соответствующие части):
#include "pcdBuffer.h"
#include <iostream>
//boost::mutex io_mutex;
pcdBuffer::pcdBuffer(int buffSize)
{
buffer.set_capacity(buffSize);
}
void pcdBuffer::put(int data)
{
{
boost::mutex::scoped_lock buffLock(bmutex);
while(buffer.full())
{
std::cout << "Buffer is full" << std::endl;
buffFull.wait(buffLock);
}
buffer.push_back(data);
}
buffEmpty.notify_one();
}
int pcdBuffer::get()
{
int data;
{
boost::mutex::scoped_lock buffLock(bmutex);
while(buffer.empty())
{
std::cout << "Buffer is empty" << std::endl;
buffEmpty.wait(buffLock);
}
data = buffer.front();
buffer.pop_front();
}
buffFull.notify_one();
return data;
}
основной драйвер для кода:
#include <iostream>
#include <boost/thread/mutex.hpp>
#include <boost/thread/thread.hpp>
#include <unistd.h>
#include "pcdBuffer.h"
pcdBuffer buff(100);
void producer()
{
int i = 10;
while (true)
{
buff.put(i);
i++;
}
}
void consumer()
{
int i;
while(true)
{
i = buff.get();
std::cout << "Data: " << i << std::endl;
}
}
int main(int argc, char** argv)
{
std::cout << "Starting main...." << std::endl;
std::cout << "Buffer Details: " << std::endl;
std::cout << "Capacity: " << buff.getCapacity() << ", isEmpty: " << buff.isEmpty() << ", isFull: " << buff.isFull() << std::endl;
boost::thread cons(consumer);
sleep(5);
boost::thread prod(producer);
prod.join();
cons.join();
return 0;
}
Моя емкость буфера правильно инициализирована до 100. Поток-потребитель ждет и сообщает, что «буфер пуст» в течение 5 секунд, но после этого я просто получаю «буфер заполнен» из метода put и «Данные: 10» из потребительская функция, чередующаяся с stdout. Как видите, 10 — это первый элемент, который я вставил. Кажется, что буфер заполняется и не уведомляет потребителя, но я проверил свои блокировки и думаю, что они верны. Любая помощь в этом очень ценится.
Вот ссылка ссылок, из которых я написал этот код:
http://www.drdobbs.com/article/print?articleId=184401518&siteSectionName=cpp
