Производители и потребители

#include <vcl.h>
#include <windows.h>
#include <iostream.h>
#include <fstream.h>
#pragma hdrstop
 
#include "Unit1.h"
char* path = new char[12];
HANDLE hWrite,hRead,hProducer,hConsumer;//дескрипторы событий и нитей
int buffer = 0,BUFFER_SIZE,PROD_SPEED,CONS_SPEED;//переменные числа сообщений в буфере, размера, скоростей
 
//для ведения логов
TDateTime df;
ofstream logthread;
 
void Producer();//заголовок функции производителя
void Consumer();//залоговок функции потребителя
void SendMess(){::buffer++;}//добавить сообщение
void ReadMess(){::buffer--;}//прочитать сообщение
 
void ProducerConsumer(int BUFFER_SIZE, int PROD_SPEED, int CONS_SPEED){//основная функция
    unsigned long uProducer, uConsumer;//для создания потока
 
    //инициализация глобальных переменных
    ::BUFFER_SIZE=BUFFER_SIZE;
    ::CONS_SPEED = CONS_SPEED;
    ::PROD_SPEED = PROD_SPEED;
    HANDLE hWrite = CreateEvent(NULL, FALSE, FALSE, NULL),//событие записи
           hRead = CreateEvent(NULL, FALSE, TRUE, NULL);//событие чтения
 
    //создание потоков
    HANDLE hProducer = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Producer, NULL, 0, &uProducer),
           hConsumer = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Consumer, NULL, 0, &uConsumer);
}
 
void Producer(){
    logthread.open(path, ios::app);
    AnsiString time = FormatDateTime("h:mm:ss",df.CurrentDateTime());
    logthread<<(time+" Поток 1 запущен \n").c_str();
    logthread.close();
    Form1->log->Lines->Add(time+" Поток 1 запущен \n");
    Form1->log->Update();
    WaitForSingleObject(hRead, INFINITE);
    while(1)
    {
        Sleep(rand()%PROD_SPEED);
        while (::buffer < ::BUFFER_SIZE){
            SendMess();
            Form1->log->Lines->Add(time+" В буфер добавлено ещё сообщение. Теперь их -"+ IntToStr(buffer) +" \n");
            Form1->log->Update();
            Sleep(rand()%PROD_SPEED);
        }
        SetEvent(hWrite);
    }
}
void Consumer()
{
    WaitForSingleObject(hWrite, INFINITE);
    while(1)
    {
        Sleep(rand()%CONS_SPEED);
        if (buffer == 0)
        {
            SetEvent(hRead);
            WaitForSingleObject(hWrite, INFINITE);
        }
        ReadMess();
    }
}
 
void __fastcall TForm1::startClick(TObject *Sender)//запускающая действо кнопка
{
int i = menu->ItemIndex;
    if(i==-1){
        ShowMessage("Пункт меню не выбран");
        return;
    }
    switch(i){
...
        case 5:{
            int buffersize = StrToInt(Edit1->Text),
            producerspeed = StrToInt(Edit2->Text),
            consumerspeed = StrToInt(Edit3->Text);
        ProducerConsumer(buffersize,producerspeed,consumerspeed);
        break;
        }
    }
}

    while (::buffer < ::BUFFER_SIZE){//это условие игнорируется
            SendMess();
            Form1->log->Lines->Add(time+" В буфер добавлено ещё сообщение. Теперь их -"+ IntToStr(buffer) +" \n");
            Form1->log->Update();
            Sleep(rand()%PROD_SPEED);
        }

void __fastcall TForm1::Button2Click(TObject *Sender)
{
unsigned long uProducer, uConsumer;//для создания потока
 
    //инициализация глобальных переменных
    ::BUFFER_SIZE=StrToInt(Edit1->Text);
    ::CONS_SPEED = StrToInt(Edit2->Text);
    ::PROD_SPEED = StrToInt(Edit3->Text);
    HANDLE hWrite = CreateEvent(NULL, FALSE, FALSE, NULL),//событие записи
           hRead = CreateEvent(NULL, FALSE, TRUE, NULL);//событие чтения
 
    //создание потоков
    HANDLE hProducer = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Producer, NULL, 0, &uProducer);
}