#ifndef Functions_ThreadsH

#define Functions_ThreadsH

 

#include <Windows.h> //Синхронизация данных разных потоков через использование критических секций.

 

//Ядро №0 - отвечает исключительно за интерфейс как действия пользователя.

 

//Ядро №1. Чтение данных и распределение по массивам. Самоконтроль. Отрисовка графика.

//Не удалось использовать несколько ядер одновременно - вся нагрузка идет на ядро №1.

class CThread_1_Core : public TThread

{

    private:

    protected:

        void __fastcall Execute();

    public:

        __fastcall CThread_1_Core(bool CreateSuspended);

    };

 

//Класс для синхронизации доступа к разделяемым данным.

class CThread_Synchronize

{

    public:

       CThread_Synchronize(); //Конструктор.

       ~CThread_Synchronize(); //Деструктор.

       void vLock(); //Заблокировать данные.

       void vUnlock(); //Разблокировать данные.

 

    private:

        //Запрет копирования.

        CThread_Synchronize(const CThread_Synchronize&);

        CThread_Synchronize& operator=(const CThread_Synchronize&);

 

        CRITICAL_SECTION m_critical_section; //Критическая секция для защиты разделяемых данных.

};

#endif

CThread_Synchronize *g_OThread_Synchronize = new CThread_Synchronize(); //Синхронизация данных потоков, чтобы ядра друг друга не перебивали, и информация не портилась.

 

CThread_1_Core *OThread_1_Core = new CThread_1_Core(false); //Операции с данными (ядро №1).

void __fastcall TForm_Main::FormClose(TObject *Sender, TCloseAction &Action)

{

    g_bForm_Loaded = false;

    OThread_1_Core->Suspend();

    OThread_1_Core->Terminate();

    //OThread_1_Core->Free(); Нельзя, виснет. delete тоже нельзя.

    //×òåíèå äàííûõ è ðàñïðåäåëåíèå ïî ìàññèâàì.

    class CThread_1_Core : public TThread

    {

    private:

    protected:

        void __fastcall Execute();

    public:

        __fastcall CThread_1_Core(bool CreateSuspended);

    };

 

    //Îòðèñîâêà ãðàôèêà.

    class CThread_2_Core : public TThread

    {

    private:

    protected:

        void __fastcall Execute();

    public:

        __fastcall CThread_2_Core(bool CreateSuspended);

    };

 

    //Åùå ÷òî-íèáóäü.

    class CThread_3_Core : public TThread

    {

    private:

    protected:

        void __fastcall Execute();

    public:

        __fastcall CThread_3_Core(bool CreateSuspended);

    };

__fastcall CThread_1_Core::CThread_1_Core(bool CreateSuspended) : TThread(CreateSuspended){}

__fastcall CThread_2_Core::CThread_2_Core(bool CreateSuspended) : TThread(CreateSuspended){}

__fastcall CThread_3_Core::CThread_3_Core(bool CreateSuspended) : TThread(CreateSuspended){}

void __fastcall TForm_Main::Timer_ImportTimer(TObject *Sender)

{

    //Çàãðóçêà äàííûõ.

    CThread_1_Core *OThread_1_Core = new CThread_1_Core(true);

    OThread_1_Core->Resume();

 

    //Ïðåäâàðèòåëüíûé ñàìîêîíòðîëü äàííûõ äðóãèì ÿäðîì.

    if (g_ORocket_Info->iRead_Count != 0)

    {

        CThread_3_Core *OThread_3_Core = new CThread_3_Core(true);

        OThread_3_Core->Resume();

    }

 

    //Îòðèñîâêà ãðàôèêà äðóãèì ÿäðîì.

    CThread_2_Core *OThread_2_Core = new CThread_2_Core(true);

    OThread_2_Core->Resume();

}

void __fastcall CThread_3_Core::Execute()

{

    SetThreadAffinityMask(GetCurrentThread(), 3 << 1); //Номер ядра, начиная с 0.

 

    g_ORocket_Info->vSelfTest(0);

 

    Terminate();

    Free();

}