Классическая задача Дж. Рихтера "Читатели-писатели" с приоритетом писателей

#include "stdafx.h"
 
#include <process.h>
#include <iostream>
static HANDLE mutAcc,mutRC,mutWC,mutReadTry;
long ReaderCount = 0;long WriterCount = 0;
using namespace std;
 
DWORD WINAPI WriterFunc(PVOID Param)    //функция потока
{
    while(1)
    {   
        WaitForSingleObject(mutAcc,INFINITE);   //проверяем, есть ли куда производить
        
        cout<< "записал"<<endl;
        Sleep(100);
        
        ReleaseSemaphore(mutAcc,1,0);
    
    }
    return NULL;
}
 
DWORD WINAPI ReaderFunc(PVOID Param)    //функция потока
{
 
    while(1)
    { //WaitForSingleObject(mutReadTry,INFINITE);
            WaitForSingleObject(mutRC,INFINITE);
            ReaderCount++;
            //InterlockedExchangeAdd(&ReaderCount,1);
            if(ReaderCount == 1)
                WaitForSingleObject(mutAcc,INFINITE);
                    ReleaseSemaphore(mutRC,1,0);
                //ReleaseSemaphore(mutReadTry,1,0);
        cout << "Прочитал" <<endl;
        Sleep(100);
        WaitForSingleObject(mutRC,INFINITE);
        ReaderCount--;
    //  InterlockedExchangeAdd(&ReaderCount,-1);
            if(ReaderCount == 0)
                        ReleaseSemaphore(mutAcc,1,0);
        ReleaseSemaphore(mutRC,1,0);
    
    }
    return NULL;
}
 
int main()
{
    setlocale(0,"rus");
    //mutAcc =  CreateMutex(NULL,FALSE,L"mutix");
    mutAcc=CreateSemaphore(NULL, 1, 1, NULL);
    mutRC = CreateSemaphore(NULL,1,1,L"full");
    mutWC = CreateSemaphore(NULL,1,1,L"full1");
    //mutReadTry = CreateSemaphore(NULL,1,1,L"full1");
    //mutRC =  CreateMutex(NULL,FALSE,L"mutix2");
    HANDLE thr[64];
    int nReader=60,nWriter=64-nReader;
    for(int i=0; i<nReader;i++)
        thr[i]=CreateThread(NULL,NULL,&ReaderFunc, NULL,NULL,NULL);
    for(int i=nReader; i<64;i++)
        thr[i]=CreateThread(NULL,NULL,&WriterFunc, NULL,NULL,NULL);
    WaitForSingleObject(thr[0], INFINITE);
    for(int i=0; i<=63;i++)
        CloseHandle(thr[i]);
    WaitForSingleObject (thr[63],INFINITE);
    CloseHandle(mutAcc);
    CloseHandle(mutRC);CloseHandle(mutWC);
    CloseHandle(mutReadTry);
    cin.get();  
    return 0;
}

#include <iostream>
#include <vector>
#include <chrono>
#include <thread>
#include <mutex>
#include <semaphore>
using namespace std::chrono_literals;
 
int readcount{}, writecount{};
std::counting_semaphore mxrc{ 1 }, mxwc{ 1 }, mxwrite{ 1 }, mxread{ 1 }, mxz{ 1 };
 
void read()
{
    while (true)
    {
        std::this_thread::sleep_for(100ms);
        mxz.acquire();
        mxread.acquire();
        mxrc.acquire();
        ++readcount;
        if (readcount == 1)
            mxwrite.acquire();
        mxrc.release();
        mxread.release();
        mxz.release();
        std::cout << "read ";
        
        mxrc.acquire();
        --readcount;
        if (readcount == 0)
            mxwrite.release();
        mxrc.release();
    }
}
 
void write()
{
    while (true)
    {
        std::this_thread::sleep_for(100ms);
        mxwc.acquire();
        ++writecount;
        if (writecount == 1)
            mxread.acquire();
        mxwc.release();
        mxwrite.acquire();
        std::cout << "write ";
        //
        mxwrite.release();
        mxwc.acquire();
        --writecount;
        if (writecount == 0)
            mxread.release();
        mxwc.release();
    }
}
 
// приоритет на запись
int main()
{
    int rc = 60, wc = 4;
    std::vector<std::thread> vt;
    for (int i = 0; i < wc; ++i)
    {
        vt.emplace_back(write);
    }
    for (int i = 0; i < rc; ++i)
    {
        vt.emplace_back(read);
    }
 
    for (auto& t : vt)
    {
        t.join();
    }
}