производитель многопоточных программ / потребитель [boost]

Основная проблема с вашим кодом заключается в том, что ваши потоки не синхронизированы.
Помните, что по умолчанию выполнение потоков не упорядочено и не упорядочено, поэтому потребительские потоки могут быть (и в вашем конкретном случае) завершены до любой поток производителя производит любые данные.

Чтобы убедиться, что потребители будут работать после того, как производители закончили свою работу, вам нужно использовать thread::join() функция на потоках производителей, она остановит выполнение основного потока до выхода производителей:

// Start producers
...

p.m_Thread.join();  // Wait p to complete
p2.m_Thread.join(); // Wait p2 to complete

// Start consumers
...

Это сделает свое дело, но, вероятно, это не хорошо для типичного варианта использования производитель-потребитель.

Чтобы добиться более полезного случая, вам нужно исправить функцию потребителя.
Ваша потребительская функция на самом деле не ждет ожидаемых данных, она просто завершится, если стек пуст, и никогда не потребляет никаких данных, если еще не было произведено никаких данных.

Это должно быть так:

void remove(ProtectedStack &s)
{
// Place your actual exit condition here,
// e.g. count of consumed elements or some event
// raised by producers meaning no more data available etc.
// For testing/educational purpose it can be just while(true)
while(!_some_exit_condition_)
{
if(s.isEmpty())
{
// Second sleeping is too big, use milliseconds instead
boost::posix_time::milliseconds workTime(1);
boost::this_thread::sleep(workTime);
}
else
{
s.pop();
}
}
}

Другая проблема не так thread использование конструктора:

m_Thread = boost::thread(&Producer::fillStack, this, s);

Цитата из Boost.Thread документация:

Конструктор потока с аргументами

template <class F,class A1,class A2,...>
thread(F f,A1 a1,A2 a2,...);

Предпосылки:
F и каждый An должен быть копируемым или подвижным.

Последствия:
Как будто thread(boost::bind(f,a1,a2,...)), Как следствие, е и каждый копируются в
внутреннее хранилище для доступа новым потоком.

Это означает, что каждый ваш поток получает свою собственную копию s и все модификации не применяются к s но в локальную ветку копирует. Это тот же случай, когда вы передаете объект в аргумент функции по значению. Вам нужно пройти s объект по ссылке вместо этого — используя boost::ref:

void produce(ProtectedStack& s)
{
m_Thread = boost::thread(&Producer::fillStack, this, boost::ref(s));
}

void consume(ProtectedStack& s)
{
m_Thread = boost::thread(&Consumer::remove, this, boost::ref(s));
}

Еще одна проблема связана с использованием мьютекса. Это не самое лучшее.

1. Почему вы используете мьютекс из библиотеки Signals2? Просто используйте boost::mutex из Boost.Thread и удалить ненужную зависимость от библиотеки Signals2.

2. Используйте оболочку RAII boost::lock_guard вместо прямого lock/unlock звонки.

3. Как уже упоминалось, вы должны защищать всех членов ProtectedStack,

Образец:

boost::mutex m;

void push(int x)
{
boost::lock_guard<boost::mutex> lock(m);
m_Stack.push(x);
}

void pop()
{
boost::lock_guard<boost::mutex> lock(m);
if(!m_Stack.empty()) m_Stack.pop();
}

int size()
{
boost::lock_guard<boost::mutex> lock(m);
return m_Stack.size();
}

bool isEmpty()
{
boost::lock_guard<boost::mutex> lock(m);
return m_Stack.empty();
}

int top()
{
boost::lock_guard<boost::mutex> lock(m);
return m_Stack.top();
}