Я совсем новичок в повышении ::потоков, я прочитал документацию, но у меня возникли некоторые проблемы с ее применением на практике, возможно вы можете помочь? Прежде всего, я потратил время на то, чтобы написать автономный листинг кода, который демонстрирует 2 типа поведения, которые я пока не могу понять...
Программа позволяет пользователю выполнять 3 разные команды,
Цель состоит в том, чтобы задача запускала некоторую работу в новом потоке, но затем возвращалась обратно в командную строку во время выполнения работы. Пользователь может дать команду info , чтобы узнать, какие задачи были выполнены, а какие нет.
Я использую двухъядерный компьютер с Win7 и Visual Studio 2008 Express.
Проблема 1>
Ввод команды task p1 p2 p3 запускает 3 задачи. Это можно проверить, выдав информацию . Через несколько секунд работа завершается, однако по какой-то причине флаг завершения не всегда устанавливается на 1 или 2 задачах.
Проблема 2>
При выходе из программы появляется следующее сообщение:
Windows активировала точку останова в файле example.exe. Это может быть связано с повреждением кучи, что указывает на ошибку в файле example.exe или любой из загруженных библиотек DLL. Это также может быть связано с тем, что пользователь нажимает клавишу F12, когда фокус находится на примере example.exe. Окно вывода может содержать дополнительную диагностическую информацию.
Надеюсь, вы сможете воспроизвести это поведение и помочь.
Заранее спасибо. Алекс.
//WARNING: THIS CODE DOES NOT BEHAVE EXACTLY AS INTENDED
#include <iostream>
#include <string>
#include <sstream>
#include <boost/thread.hpp>
using namespace std;
class task {
public:
string mname;
bool completed;
void start()
{
int a = 0;
for (int i=0 ; i<10000; i++)
{
for (int j=0 ; j<100000; j++)
{
a= i*2;
}
}
this->completed = true;
}
task(string name)
{
mname = name;
completed = false;
}
};
class taskManager{
public:
boost::thread_group threads;
void startTask( string name )
{
//add new task to vector list
mtasks.push_back( task(name) );
// execute start() on a new thread
threads.create_thread( boost::bind( &task::start, &mtasks.back()) );
}
int tasksTotal()
{
return mtasks.size();
}
string taskInfo(int i)
{
string compstr("Not Completed");
if ( mtasks[i].completed == true )
{
compstr = "Completed";
}
return mtasks[i].mname + " " + compstr;
}
private:
vector<task> mtasks;
};
int main(int argc, char* argv[])
{
string cmd, temp;
stringstream os;
bool quit = false;
taskManager mm;
cout << "PROMPT>";
while (quit == false)
{
//Wait for a valid command from user
getline(cin,cmd);
// Reset stringstream and assign new cmd string
os.clear();
os << "";
os << cmd;
//parse input string
while (os >> temp)
{
if ( temp.compare("task") == 0 )
{
while (os >> temp) { mm.startTask( temp ); }
}
if ( temp.compare("info") == 0 )
{
// Returns a list of all completed and not completed tasks
for (int i = 0; i<mm.tasksTotal(); i++)
{
cout << mm.taskInfo(i).c_str() << endl;
}
}
if ( temp.compare("quit") == 0 ){ quit = true; }
}
cout << "PROMPT>";
}
mm.threads.join_all();
return 0;
};