C ++ Boost Multithread CPU и использование памяти медленные и высокие - нужна помощь

Question

Я использую библиотеку boost для создания многопоточности с мьютексом.Я на основе какого-то примера на Google.Многоголовки работают нормально, но загрузка процессора составляет 100%, использование памяти из диспетчера задач составляет более 300 КБ.Мои две многопоточные функции выполняют очень высокое преобразование данных и анализ.Я не уверен, что что-то упустил.Вот часть моей многопоточности:

wait(1); 
mutex.lock();
boost::thread t1(&YExcel::BasicExcelCell::TTiTraceParserConv,c,TTiAsciiTraceOutputDL.GetBuffer(0));
mutex.unlock();
wait(2); 
mutex.lock();
boost::thread t2(&YExcel::BasicExcelCell::TTiTraceParserConv,c,TTiAsciiTraceOutputUL.GetBuffer(0));
mutex.unlock();
t1.join();
t2.join();
wait(2); 

wait(1); 
mutex.lock();
boost::thread t5(&YExcel::BasicExcelCell::UeAndCellParamParseUL,c,TTiAsciiTraceOutputUL.GetBuffer(0), NumOfLinesUL,GHOSTFILTER);
mutex.unlock();
wait(2); 
mutex.lock();
boost::thread t6(&YExcel::BasicExcelCell::UeAndCellParamParseDL,c,TTiAsciiTraceOutputDL.GetBuffer(0), NumOfLinesDL);
mutex.unlock();
t5.join();
t6.join();

Нужно ли что-то делать внутри этих функций?Заранее спасибо.Я был протестирован с Dell Optilex 745 Pentium D. Я не уверен, что он поддерживает многопоточность.Я напечатал hard_concurrent, он показывал 1.

Одна из функций - сводка

int BasicExcelCell::UeAndCellParamParseDL(char *inname, int NumOfRecords)
{
typedef boost::tokenizer <boost::escaped_list_separator<char> > my_tokenizer;   
....
....
CString TTiAsciiTraceOutput(inname);
TTiAsciiTraceOutput.Replace(".dat","_raw.txt");

ifstream infile(TTiAsciiTraceOutput.GetBuffer(0));
if (!infile)
{
    cout << "Couldn't open file " << TTiAsciiTraceOutput.GetBuffer(0) << " for reading." << endl;
    return EXIT_FAILURE;
}
cout << "\nOpened file " << TTiAsciiTraceOutput.GetBuffer(0) << " for reading." << endl << endl;

int lineCount=0;
getline(infile, line);
if (NumOfRecords < 0)
{
    cout<<"Number Of Lines to be parsed is not specified!"<<endl;
    return 0;
}
while (getline(infile, line) && lineCount <= NumOfRecords)
{       
    lineCount++;
    int FoundCrntiEmpty=0;

    my_tokenizer tok(line);
    int i = 0;

    for (my_tokenizer::iterator it(tok.begin()), end(tok.end()); it != end; ++it)
    { 
        mystr.push_back(*it);
    }

    int tokcount=0;
    int SingleTx=0;
    int TxDiv=0;
    int tokCountFlag=0;
    double MetricCalTemp=0.0;

    for (vector < string >::iterator mit(mystr.begin()); mit != mystr.end(); mit++)
    {
        for (vector < string >::iterator _mit(mystr.begin()); _mit != mystr.end(); _mit++)
        {
            tokCountFlag++;
            if (tokCountFlag==60)
                break;//not need to goto the whole iterator

            switch (tokCountFlag)
            {
                case 29: 
                     <<*_mit<<endl; 
                        if (*_mit=="0")
                            FoundCrntiEmpty=1;
                    break;

                case 58:
                    //cout<<"Single or Tx " <<*_mit<<endl;

                    if (*_mit == "0")
                        SingleTx=1;
                    else if (*_mit == "1")
                        TxDiv=1;

                    break;
            }
        } 
       }
 }

Еще одна короткая функция в первом потоке:

void BasicExcelCell::TTiTraceParserConv(char *p_resFile)
{

char ttiTraceParser[512];
char ttiTraceConfig[512];
char cwd[512];

size_t size;

char OrigDLFile[512];

GetModuleFileName(NULL, cwd, 512);
char * CollectTTiTraceAdvance_exe;
CollectTTiTraceAdvance_exe = strstr (cwd,"CollectTTiTraceAdvance.exe");
strncpy (CollectTTiTraceAdvance_exe,"",26);

CString TTiAsciiTraceOutput(p_resFile);
CString ParserExe, TraceConfig;

ParserExe.Format(_T("%s\\BinaryFileParser\\tti_trace_parser_wmp.exe "),cwd);

sprintf(OrigDLFile,"%s",TTiAsciiTraceOutput.GetBuffer(0));
TTiAsciiTraceOutput.Replace(".dat","_raw.txt");
TraceConfig.Format(_T(" %s\\%s %s\\%s"),cwd,OrigDLFile,cwd,TTiAsciiTraceOutput);

cout<<"\n\n****Prepare to generate RawFile!!!"<<endl;
ShellAndWait(ParserExe.GetBuffer(0),TraceConfig.GetBuffer(0),"WAIT",240,1);//4 minutes

ParserExe.ReleaseBuffer(0);
TraceConfig.ReleaseBuffer(0);
}

Answer 1

Мне это не кажется правильным:

mutex.lock();
boost::thread t6(...);
mutex.unlock();

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

Кроме того, как указано в комментариях, wait являются подозрительными и не должны быть необходимы.

Наконец, вы (на мой взгляд) никогда не должны использовать mutex.lock / mutex.unlock напрямую, потому что он подвержен ошибкам, особенно при наличии исключений.Используйте инструменты RAII, такие как scoped_lock, предоставляемые Boost.

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