Семафоры

#include <vector>
#include <string>
#include <fstream>
#include <sstream>
#include <thread> 
#include <ctime>
#include <cctype>
#include <map>
#include <iostream>
#include <windows.h>
#include <process.h>
#include <iterator>
#include <algorithm>
 
using namespace std;
map <string, int> map2;
 
HANDLE hSemaphore;
// имя семафора
const char lpSemaphoreName[] = "MySemaphore";
 
string formatStr(string& str)//убираем лишн. символы
{
    string newStr = "";
 
    for (int i = 0; i < str.size(); i++)
    {
        if (!isalpha((unsigned char)str[i]))
            continue;
 
        char ch = tolower(str[i]);
        newStr.push_back(ch);
 
    }
    return newStr;
}
 
 
 
void formatFileV2(vector<string>* text, int start, int end)//текст из файла отпр. в вектор слов
{
    for (int i = start; i <= end; i++)
    {
        text->at(i) = formatStr(text->at(i));
    }
 
    return;
}
 
vector<string>* filePars(string fileName)//из файла получаем текст и символы
{
    vector <string>* vec = new vector < string >;
    ifstream file(fileName);
 
    if (!file.is_open())
        return nullptr;
 
    string word;
 
    while (file >> word)
    {
        vec->push_back(word);
    }
 
    return vec;
}
 
 
void сounterWords2(int  numth, vector <string>* text, int start, int end)//участки заполнения мар для потоков
{
    if ( !text->size()) //Если хотя бы один вектор пуст
        return;
 
    if (start < 0 || end > text->size() - 1 || end < start)
        return;
 
    if (end - start + 1 < 1)
        return;
 
    int num = 0;
 
    for (int i = start ; i <= end; i++)
    {
        
            string sT;
            sT = text->at(i );
            if (WaitForSingleObject(hSemaphore, 30000) == WAIT_FAILED)
                            return;
            
            for (char a = 'а'; a <= 'я'; a++)
            {
                
                for (char b = 'а'; b <= 'я'; b++)
                {
                    for (char c = 'а'; c <= 'я'; c++)
                    {
                        
 
                        char tripple[4] = { a, b, c, '\0' };
                        size_t found = sT.find(tripple);
                        
                        if (found != std::string::npos)
                            map2[tripple]++;
                        
                    }
                }
            }
 
            if (hSemaphore != NULL)
                            ReleaseSemaphore(hSemaphore, 1, NULL);
        }
    return;
}
 
int main(int argc, char *argv[])
{
 
    setlocale(LC_ALL, "rus");
    ofstream result("result.txt");
    std::cout << "Program was started" << endl;
 
    string fileName("Пушкин2.txt");
    int numberOfProcesses = 2;
    hSemaphore = CreateSemaphore(NULL, 1, 1, lpSemaphoreName);
    if (hSemaphore == NULL) {
        std::cout << "Sem dont created" << endl;
        return FALSE;
    }
    if (argc >= 3)
    {
        fileName = argv[1];
        numberOfProcesses = atoi(argv[2]);
    }
    float frequency = 0;
    int n = 0;
 
    vector<string> *vecText = filePars(fileName);
 
    if (vecText == nullptr )
    {
        std::cout << "error in reading data" << endl;
        return 1;
    }
 
    unsigned int vremPosleChtenia = clock();
 
    
    int textSize = vecText->size();
 
    if (vecText->size() < 1 * numberOfProcesses)
    {
        //Не делим на процессы
        сounterWords2( 1, vecText, 0, textSize - 1); //Числитель - число появлений конкретной nGramm-ы
        
    }
    else
    {
        //Делим на процессы
        vector<thread*> vecThreads;
        vector<int> vecAnswers(numberOfProcesses);
 
        int step = textSize / numberOfProcesses; //Пример: 8-длина текста, 2- число проц. 8/2=4
        int start = 0;                      //от 0
        int end = step - 1;                 //до 3 и от 4 до 7
 
        for (int i = 1; i <= numberOfProcesses; i++)
        {
            auto th = new std::thread(formatFileV2, vecText, start, end);
            vecThreads.push_back(th);
 
            start = end ;
 
            //последний процесс захватывает все слова до конца
            if (i == numberOfProcesses)
                end = textSize - 1;
            else
                end = end + step;
        }
        numberOfProcesses = 4;
        for (auto &th : vecThreads)
        {
            th->join();
            delete th;
        }
        vecThreads.clear();
 
        step = textSize / numberOfProcesses; //Пример: 8-длина текста, 2- число проц. 8/2=4
        start = 0;                      //от 0
        end = step - 1;                 //до 3 и от 4 до 7
 
        for (int i = 1; i <= numberOfProcesses; i++)
        {
            //if(i==1)
            auto th = new std::thread(сounterWords2, i, vecText, start, end);
 
            vecThreads.push_back(th);
 
            start = end ;
 
            //последний процесс захватывает все слова доконце
            if (i == numberOfProcesses)
                end = textSize - 1;
            else
                end = end + step;
        }
 
        for (auto &th : vecThreads)
        {
            th->join();
            delete th;
        }
 
        
    }
    
    std::cout.setf(std::ios::fixed);
 
    delete vecText;
 
    unsigned int vremKonca = clock();
    unsigned int vremRaboti = (vremKonca - vremPosleChtenia);//в секундах
    
    for (auto it = map2.begin(); it != map2.end(); ++it) {
        result << it->first << " : " << it->second << endl;
    }
    
    cout << "Время работы программы  = " << vremKonca << endl; // время работы программы  
    cout << "Time = " << vremRaboti << endl; // время работы программы без чтения 
    CloseHandle(hSemaphore);
    
 
    ofstream fout("Statistics.txt", ios_base::app); // открываем файл для добавления информации к концу файла
 
    if (!fout.is_open()) // если файл не открыт
        cout << "Файл не может быть открыт!\n"; // сообщить об этом
 
    fout << vremRaboti << endl;
    fout.close();
    result.close();
    system("pause");
    return 0;
}