Notes

#include <iostream>
#include <thread>
#include <chrono>
#include <mutex>
//możliwiają oczekiwanie na spełnienie określonego warunku
#include <condition_variable>
//generator liczb loscNych
#include <random>
using namespace std;
//czas przez jaki producent będzie generował znaki

const int CZAS_PRACY=5;

//Monitor - pojemnik przechowujący dane i zapewniający
//synchronizację wątków
template <typename TypDanych>
class Monitor
{

private:
TypDanych dane;
bool saDane; //czy dane są aktualne

mutex mutexDane;
//umożliwia czekanie na ncxe dane

condition_variable warunekSaNoweDane;
// umożliwia na opróżnienie pojemni ka

condition_variable warunekZabranoDane;
public:
Monitor()
{

saDane=false; // na początku pojemnik jest pusty
}
void zapisz(TypDanych noweDane)
{
unique_lock<mutex> blokada(mutexDane);
if (saDane) warunekZabranoDane.wait(blokada);
saDane=true;
dane=noweDane;

}
TypDanych odczytaj()
{


unique_lock<mutex> blokada(mutexDane);

if (!saDane) warunekSaNoweDane.wait(blokada);
saDane=false;

warunekZabranoDane.notify_one();
return dane;
}
};
class Producent
{

private:

int czas;

Monitor< char >& pojemnik;

char biezacyZnak;

minstd_rand generator; //algorytm generatora liczb pseudolosowych
uniform_int_distribution< char > rozklad; //rozkład liczb pseudolosowych
public:
//tworzenie producenta generującego znaki [a,z]
Producent(Monitor < char >& _pojemnik):
czas(0), pojemnik(_pojemnik), biezacyZnak('a'),
generator(random_device()()),rozklad('a', 'z')
{

}

void operator()()
{
while (czas<CZAS_PRACY)
{

pojemnik.zapisz(biezacyZnak);
biezacyZnak=(biezacyZnak+1-97)%25+97;
//potem dla urozmaicenia
//zamiast kolejnych można zpisywać losowe znaki
//pojemnik.zapisz(rozklad(generator));
//przerwa w pracy
this_thread::sleep_for(chrono::seconds(1));
++czas;
}
//znak "koniec pliku' powoduje zakończenie konsumenta
pojemnik.zapisz(EOF);
}
};
class Konsument
{

private:
//referencja do wspólnego pojemnika
Monitor< char >& pojemnik;
public:
//tworzenie konsumenta
Konsument(Monitor< char >& _pojemnik): pojemnik(_pojemnik) {}
//kod wykonywany w wątku
void operator()()
{
char znak=pojemnik.odczytaj();
while (znak!=EOF)
{
cout<<znak<<endl;
znak=pojemnik.odczytaj();
}
}
};
int main(int argc, char** argv)
{

random_device r;
minstd_rand generator(r()) ;
//tworzenie wspólnego pojemnika dla konsumenta i producenta
Monitor< char > pojemnik;
//tworzenie producenta i konsumenta
Konsument konsument(pojemnik);
Producent producent(pojemnik);
//tworzenie wątków
thread wk(konsument);
thread wp(producent);
//czekanie na zakończenie wątków
wp.join();
wk.join();
return (EXIT_SUCCESS);
}