Boost ::пример потоков и сообщение о повреждении кучи

Я совсем новичок в повышении ::потоков, я прочитал документацию, но у меня возникли некоторые проблемы с ее применением на практике, возможно вы можете помочь? Прежде всего, я потратил время на то, чтобы написать автономный листинг кода, который демонстрирует 2 типа поведения, которые я пока не могу понять...

Программа позволяет пользователю выполнять 3 разные команды,

  • задача [имя ]
  • info
  • quit

Цель состоит в том, чтобы задача запускала некоторую работу в новом потоке, но затем возвращалась обратно в командную строку во время выполнения работы. Пользователь может дать команду 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;  
};
7
задан inf 29 April 2012 в 15:49
поделиться