Передача объекта класса в качестве аргумента для boost :: thread

У меня есть функция с именем «продюсер», которая принимает объект класса в качестве аргумента. Я пытаюсь создать поток для производителя, используя boost :: thread. Однако это вызывает ошибку из-за объекта класса, который я передаю в качестве аргумента. Я не могу понять, почему это дает ошибку. Если я удаляю аргументы функции и позволяю ей передаваться как глобальная переменная, она работает нормально. Ниже мой код.

BlockingQueue.h

#ifndef BLOCKINGQUEUE_H_
#define BLOCKINGQUEUE_H_

#include <queue>
#include <iostream>
#include <boost/thread.hpp>

template<class T>
class BlockingQueue
{
private:
std::queue<T>               m_queBlockingQueue;
boost::condition_variable   m_cvSignal;
boost::mutex                m_mtxSync;

public:
BlockingQueue();
bool isEmpty();
T& popElement();
void pushElement(T nElement);
virtual ~BlockingQueue();
};

template<class T>
BlockingQueue<T>::BlockingQueue()
{
}

template<class T>
bool BlockingQueue<T>::isEmpty()
{
bool bEmpty;
boost::mutex::scoped_lock lock(m_mtxSync);
m_cvSignal.wait(lock);
bEmpty = m_queBlockingQueue.empty();
return bEmpty;
}

template<class T>
T& BlockingQueue<T>::popElement()
{
boost::mutex::scoped_lock lock(m_mtxSync);
while (m_queBlockingQueue.empty())
{
m_cvSignal.wait(lock);
}
T& nElement = m_queBlockingQueue.front();
m_queBlockingQueue.pop();
return nElement;
}

template<class T>
void BlockingQueue<T>::pushElement(T nElement)
{
boost::mutex::scoped_lock lock(m_mtxSync);
m_queBlockingQueue.push(nElement);
m_cvSignal.notify_one();
}

template<class T>
BlockingQueue<T>::~BlockingQueue()
{
}

#endif /* BLOCKINGQUEUE_H_ */

main.cpp

#include "BlockingQueue.h"
#include <iostream>

using namespace std;

void producer (BlockingQueue<int>& blockingQueue)
{
for (int i=0; i<100; i++)
{
cout<<"Producer about to push("<<i<<")..."<<endl;
blockingQueue.pushElement(i);
sleep(1);
}
}

void consumer (BlockingQueue<int>& blockingQueue)
{
for (int i=0; i<100; i++)
{
cout<<"Consumer received: "<<blockingQueue.popElement()<<endl;
sleep(3);
}
}

int main ()
{
BlockingQueue<int> blockingQueue;
cout<<"Program started..."<<endl;
cout.flush();

boost::thread tConsumer(consumer, blockingQueue);
boost::thread tProducer(producer, blockingQueue);

tProducer.join();
tConsumer.join();

return 0;
}

Ошибки, которые я получаю, примерно такие:

1) нет известного преобразования для аргумента 1 из «const BlockingQueue» в «BlockingQueue»&»
2) BlockingQueue :: BlockingQueue (BlockingQueue&в этом контексте
3) нет соответствующей функции для вызова ‘BlockingQueue :: BlockingQueue (const BlockingQueue&)»

У меня есть другие ошибки, такие как:
thread.hpp: 148: 47: ошибка: инициализация аргумента 1 из статического повышения :: detail :: thread_data_ptr boost :: thread :: make_thread_info (F) [с F = boost :: _ bi :: bind_t&), boost :: _ bi :: list1>>>, boost :: detail :: thread_data_ptr = boost :: shared_ptr] ’

Есть ли какая-то функция, как конструктор копирования и т. Д. В моем классе, который отсутствует или что. Если я использую свой код для передачи примитивных типов данных, таких как int, double это работает нормально. Это была проблема с моим классом «BlockingQueue».

0

Решение

Если вы хотите передать по ссылке, вам нужно использовать boost :: ref или просто указатель. boost :: thread копирует по значению, и поэтому не может использовать вашу функцию передачи по ссылке. Например, вы можете сделать:

#include "BlockingQueue.h"
#include <iostream>

using namespace std;

void producer (boost::reference_wrapper<BlockingQueue<int>> blockingQueue)
{
for (int i=0; i<100; i++)
{
cout<<"Producer about to push("<<i<<")..."<<endl;
blockingQueue.get_pointer()->pushElement(i);
sleep(1);
}
}

void consumer (boost::reference_wrapper<BlockingQueue<int>> blockingQueue)
{
for (int i=0; i<100; i++)
{
cout<<"Consumer received: "<<blockingQueue.get_pointer()->popElement()<<endl;
sleep(3);
}
}

int main ()
{
BlockingQueue<int> blockingQueue;
cout<<"Program started..."<<endl;
cout.flush();

boost::thread tConsumer(consumer, ref(blockingQueue));
boost::thread tProducer(producer, ref(blockingQueue));

tProducer.join();
tConsumer.join();

return 0;
}
2

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]