Странная работа потока - C++ Builder - Ответ 7784666

//---------------------------------------------------------------------------
#include <list.h>
#include <vcl.h>
#pragma hdrstop
 
#include "Thread.h"
#include "ClassThread.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TForm1 *Form1;
CRITICAL_SECTION cs;
TGenThread *MainThread;
TGenThread *GenThread;
TGenThread *GenThread1;
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
        : TForm(Owner)
{
        InitializeCriticalSection(&cs);
 
}
//---------------------------------------------------------------------------
void __fastcall TForm1::CreateThread() {
        terminate = 0; // сбрасываем флаг завешения работы
        //создаем три потока
        MainThread = new TGenThread(true);
        GenThread = new TGenThread(true);
        GenThread1 = new TGenThread(true);
* * * * //инициализируем их
        MainThread->Priority = tpHigher;
        MainThread->Init(0);
        GenThread->Priority = tpHigher;
        GenThread->Init(1);
        GenThread1->Priority = tpHigher;
        GenThread1->Init(2);
* * * * //запускаем главный поток (поставщик данных для двух других)
        MainThread->Resume();
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Execute() {
 
        for ( int i = 1 ; i < 5 ; ++i ) {
                        flag = 0; // сброс флага завершенных потоками вычислений
                        it = i; // заносим в глобальную переменную новые данные для обработки
                        GenThread->Resume(); // запускаем поток 1
                        GenThread1->Resume(); // запускаем поток 2
                        MainThread->Suspend(); // останавливаем главный поток
        }
        terminate = 1; // выставляем флаг завершения работы
        GenThread->Resume(); // запускаем выход цикла в поток 1 
        GenThread1->Resume(); // запускаем выход цикла в поток 2  
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Generation() {
                        while (!terminate) { 
                        EnterCriticalSection(&cs);
                                listData.push_back(it+10); // обработка данных
                                flag++; // увеличиваем флаг отработанных потоков
                        LeaveCriticalSection(&cs);
                        if ( flag == 2 ) MainThread->Resume(); // проверяем флаг, если этот поток завершил вычисления последним, то запускаем главный поток
                        GenThread->Suspend(); // останавливаем поток 1
                        }
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Generation1() {
                        while (!terminate) {
                        EnterCriticalSection(&cs);
                                listData.push_back(it+100); // обработка данных
                                flag++;  // увеличиваем флаг отработанных потоков
                        LeaveCriticalSection(&cs);
                        if ( flag == 2 ) MainThread->Resume();  // проверяем флаг, если этот поток завершил вычисления последним, то запускаем главный поток
                        GenThread1->Suspend(); // останавливаем поток 1
                        }
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::Button1Click(TObject *Sender)
{
        CreateThread(); // создание потоков по нажатию на кнопке
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::Button2Click(TObject *Sender)
{
        Memo1->Lines->Add("-----");
        for ( list<int>::iterator it = listData.begin() ; it != listData.end() ; ++it ) {
                Memo1->Lines->Add(*it);
        }
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::FormClose(TObject *Sender, TCloseAction &Action)
{
        DeleteCriticalSection(&cs);
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
void __fastcall TGenThread::Execute()
{
        FreeOnTerminate = true; //флаг освобождения памяти при завершении потока
        // запуск функции в потоке в зависимости от ключа инициализации
        if (NumF == 0) {
                Form1->Execute(); //
        } else if (NumF == 1) {
                Form1->Generation();
        } else if (NumF == 2) {
                Form1->Generation1();
        } else {};
}
 
//---------------------------------------------------------------------------
void  __fastcall TGenThread::Init( int NumF_)
{
        NumF = NumF_; // Создаем ключ для запуска
}