Мне нужно написать программу, которая выполняет вычисления, требующие больших вычислительных ресурсов. Программа может работать несколько дней. Расчет можно легко разделить на разные потоки без необходимости использования общих данных. Мне нужен графический интерфейс или веб-служба, которая информирует меня о текущем состоянии.
Мой текущий дизайн использует BOOST::signals2 и BOOST::thread. Он компилируется и пока работает так, как ожидалось. Если поток завершил одну итерацию и доступны новые данные, он вызывает сигнал, который подключается к слоту в классе GUI.
Мои вопросы):
- Является ли эта комбинация сигналов и потоков разумной идеей? На другом форуме кто-то посоветовал кому-то не "идти по этой дороге".
- Есть ли поблизости потенциальные смертельные ловушки, которые я не заметил?
- Реалистично ли мое ожидание, что будет «легко» использовать мой класс GUI для предоставления веб-интерфейса или QT, VTK или любого другого окна?
- Есть ли более умная альтернатива (например, другие библиотеки повышения), которую я упустил?
следующий код компилируется с
g++ -Wall -o main -lboost_thread-mt <filename>.cpp
код следует:
#include <boost/signals2.hpp>
#include <boost/thread.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <iterator>
#include <string>
using std::cout;
using std::cerr;
using std::string;
/**
* Called when a CalcThread finished a new bunch of data.
*/
boost::signals2::signal<void(string)> signal_new_data;
/**
* The whole data will be stored here.
*/
class DataCollector
{
typedef boost::mutex::scoped_lock scoped_lock;
boost::mutex mutex;
public:
/**
* Called by CalcThreads call the to store their data.
*/
void push(const string &s, const string &caller_name)
{
scoped_lock lock(mutex);
_data.push_back(s);
signal_new_data(caller_name);
}
/**
* Output everything collected so far to std::out.
*/
void out()
{
typedef std::vector<string>::const_iterator iter;
for (iter i = _data.begin(); i != _data.end(); ++i)
cout << " " << *i << "\n";
}
private:
std::vector<string> _data;
};
/**
* Several of those can calculate stuff.
* No data sharing needed.
*/
struct CalcThread
{
CalcThread(string name, DataCollector &datcol) :
_name(name), _datcol(datcol)
{
}
/**
* Expensive algorithms will be implemented here.
* @param num_results how many data sets are to be calculated by this thread.
*/
void operator()(int num_results)
{
for (int i = 1; i <= num_results; ++i)
{
std::stringstream s;
s << "[";
if (i == num_results)
s << "LAST ";
s << "DATA " << i << " from thread " << _name << "]";
_datcol.push(s.str(), _name);
}
}
private:
string _name;
DataCollector &_datcol;
};
/**
* Maybe some VTK or QT or both will be used someday.
*/
class GuiClass
{
public:
GuiClass(DataCollector &datcol) :
_datcol(datcol)
{
}
/**
* If the GUI wants to present or at least count the data collected so far.
* @param caller_name is the name of the thread whose data is new.
*/
void slot_data_changed(string caller_name) const
{
cout << "GuiClass knows: new data from " << caller_name << std::endl;
}
private:
DataCollector & _datcol;
};
int main()
{
DataCollector datcol;
GuiClass mc(datcol);
signal_new_data.connect(boost::bind(&GuiClass::slot_data_changed, &mc, _1));
CalcThread r1("A", datcol), r2("B", datcol), r3("C", datcol), r4("D",
datcol), r5("E", datcol);
boost::thread t1(r1, 3);
boost::thread t2(r2, 1);
boost::thread t3(r3, 2);
boost::thread t4(r4, 2);
boost::thread t5(r5, 3);
t1.join();
t2.join();
t3.join();
t4.join();
t5.join();
datcol.out();
cout << "\nDone" << std::endl;
return 0;
}
out- person nos schedule 11.06.2010