программа работает бесконечно - Visual C++ - Ответ 4339769

#include "stdafx.h"
#include "stdio.h"
#include "windows.h"
#include "time.h"
#include <process.h>
#include <stdlib.h>
#include <stdio.h>
 
 
///////////////////////////описания классов////////////////////////////////////
int chislo = 1;
class Threads
{
public:
    Threads(void){};
    ~Threads(void) {};
    Threads *next;
    DWORD thr;
};
 
class Treadlist
{
public:
    Threads *head;
    Threads *trail;
    Treadlist(void)
    {
        head = NULL;
        trail = head;
    };
    ~Treadlist(void) {};
 
    void addtolist(DWORD curthread)//добавить поток в список curthread-следующий поток
    {
        Threads *one = new Threads;
        one->next = NULL;
        one->thr = curthread;
        if (head)
        {
            trail->next = one;
            trail = one;
        }
        else
        {
            head = one;
            trail = head;
        }
    }
 
    DWORD remove()//удалить покток из списка
    {
        DWORD one;
        Threads *two;
        if (head)
        {
            one = head->thr;
            two = head;
            head = head->next;
            delete two;
        }
        else one = NULL;
        return one;
    }
} ;
 
class mycsec
{
public:
    long busy;
    mycsec(void)
    {
        busy=0;
    };
    ~mycsec(void) {};
 
    void lock()
    {
        while (1)
        {
            if (InterlockedExchange(&busy,1))//InterlockedExchange(&busy,1) 1-ый переменная для установки в заданное значение 2-ая значение которое устонавливается 
                SwitchToThread();//Заставляет поток вызова уступить исполнение в другой поток, который готов работать на текущем процессоре. Операционная система выбирает следующего потока для выполнения.
            else break;
        }
    }
 
    void unlock()
    {
        busy = 0;
    }
} section ;
 
 class Buffer
{
public:
    int size,first,last;
    Buffer(void)
    {
        size = 5;
        first = 0;
        last = -1;
    };
    ~Buffer(void) {};
 
    int portions[5];
 
    int make_portion()//создаем порцию
    {
        time_t t;
        srand((unsigned) time(&t));
        int portion = chislo;//last+2;     //rand()%t%9 + 1;
        last++;
        last = last%5;
        portions[last] = portion;
        chislo++;
        printf("produced= %d;\n",portion);
        return portion;
    }
 
    int get_portion()//используем порцию
    {
        int portion = portions[first];
        portions[first] = 0;
        first++;
        first = first%5;
        printf("consumed= %d;\n",portion);
                return portion;
    }
} mybuf;
 
 class Semaphore
{
public:
    int count;
    Semaphore(int num)
    {
        count = num;
    }
 
    ~Semaphore(void) {};
 
    //mycsec section;
 
    Treadlist mylist;
    void up()
    {
        section.lock();
        count++;
        if (count == 1) 
        {
            if (mylist.head)
            {
                DWORD q = mylist.remove();
                HANDLE h = OpenThread(THREAD_ALL_ACCESS,1,q);//1) право доступа 2)Указывает, является ли новый процесс наследуемым в ручную 3)Идентификатор потока (дейсвие)
                //printf("\n%d void UP\n",q);
                printf("void UP\n");
                ResumeThread(h);
            }
        }
        section.unlock();
    }
 
    void down()
    {
        section.lock();
        if(count == 0)
        {
            HANDLE h = OpenThread(THREAD_ALL_ACCESS,1,GetCurrentThreadId());
            mylist.addtolist(GetCurrentThreadId());
            section.unlock();
 
            SuspendThread(h);//Приостанавливает действие указанного потока.
            section.lock();
            if (count != 0) {count--;}
            section.unlock();
        }
        else 
        {
            count--;
            section.unlock();
        }
        
    }
};
///////////////////////////конец описания классов////////////////////////////////////
 
 
Semaphore empty(5);
Semaphore full(0); 
Semaphore mutex(1);
 
 
DWORD WINAPI producer(LPVOID p)
{
    int portion;
    while(1)
    { 
        
        empty.down();
        mutex.down();
        portion = mybuf.make_portion();
        mutex.up();
        full.up();
        Sleep(1000);
    }
} 
 
 
DWORD WINAPI consumer(LPVOID p)
{
    int portion;
    while(1)
    { 
        Sleep(1000);
        full.down();
        mutex.down();
        portion = mybuf.get_portion();
        mutex.up();
        empty.up();
        
        
    }
} 
 
 
 
int _tmain(int argc, _TCHAR* argv[])
{
     
     HANDLE con1 = CreateThread(NULL,0,consumer,NULL,0,NULL);
     HANDLE pr1 = CreateThread(NULL,0,producer,NULL,0,NULL);
     HANDLE con2 = CreateThread(NULL,0,consumer,NULL,0,NULL);
     HANDLE pr2 = CreateThread(NULL,0,producer,NULL,0,NULL);
     WaitForSingleObject(con1,INFINITE);
 
    return 0;
}