Il s’agit d’un des codes d’exemple du livre écrit par Bjarne Stroustrup et qui est disponible ici. Le contenu de ce livre correspond au début du livre The C++ Programming Language qu’on trouve ici.
Pour chaque exemple, j’ai essayé de faire en sorte que le code se compile, soit complètement autonome et tienne dans un seul source.
J’ai aussi tenté d’avoir des sorties à l’écran afin que l’on se rende compte un peu mieux de se qui se passe vraiment.
Oui, oui bien sûr, il y a des cas où il faut aller vérifier avec un débogueur.
En tout cas l’objectif est de pouvoir avoir un code fonctionnel qu’on puisse compiler et dans lequel on puisse naviguer.
J’ai tenté de coller au maximum aux exemples du bouquin. Dans un ou deux cas, j’ai dû renommer certaines variables.
J’ai surtout travaillé avec Visual Studio Community 2013.
Ceci dit les exemples tournent dans Ideone.com ou la version en ligne du compilateur C++ de Microsoft.
Dans certains cas j’ai aussi fait aussi des tests avec le compilateur clang de mon Mac.
Pour utiliser le code, il suffit de faire un copier coller et zou c’est parti.
Pour les explications, bien sûr, il vaut mieux se référer aux livres de l’auteur.
Notes spécifiques à cet exemple
ATTENTION : Mi Août 2015 - Il semble qu'il y a des fuites mémoire quand j’exécute se code avec MSVC 2015. Je ne sais plus si il y en avait avec MSVC 2013. Je suis en train de faire des test. J'ai essayé d'autre code, d'autre personnes. Je pense que c'est soit une fuite dans la STL ou bien une erreur de ma part dans la façon de tracker les fuites.
Bien comprendre que le thread principal s'endort pour n secondes et que pendant ce temps les 2 threads producer() et consumer() travaillent en parallèle. Il y a quelques modifications par rapport au code initial car je souhaitais avoir un truc qui bouge à l'écran.
Le code source
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
#ifdef _MSC_VER#define _CRTDBG_MAP_ALLOC#include <crtdbg.h>#endif // _MSC_VER#include <iostream> #include <queue>#include <condition_variable>#include <mutex>#include <thread>using namespace std;using namespace std::chrono; // see §11.4bool gRun = true;struct Message { // object to be communicated int Index;};queue<Message> gQueue; // the queue of messagescondition_variable gCond; // the variable communicating eventsmutex gMutex; // the locking mechanism// ----------------------------------------------------------------------------void producer(){ static int count = 0; while (gRun) { //this_thread::sleep_for(seconds{ 1 }); // may be used to generate a message every second Message m; m.Index = ++count; cout << "producing index : " << m.Index << endl; unique_lock<mutex> lock{ gMutex }; // protect operations gQueue.push(m); gCond.notify_one(); // notify } // release lock (at end of scope)}// ----------------------------------------------------------------------------void consumer(){ while (gRun) { unique_lock<mutex> lock{ gMutex }; // acquire gMutex gCond.wait(lock); // re-acquire lock upon wakeup while (!gQueue.empty()){ // get one or more messages auto m = gQueue.front(); cout << "consuming index : " << m.Index << endl; gQueue.pop(); // Removes an element from the front of the queue } lock.unlock(); // release lock }}// ----------------------------------------------------------------------------void Test(void) { thread t1{ producer }; thread t2{ consumer }; this_thread::sleep_for(seconds{ 10 }); cout << "Test finished to wait" << endl; gRun = false; t1.join(); t2.join();}// ----------------------------------------------------------------------------int main() { try{#ifdef _MSC_VER _CrtSetDbgFlag(_CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF);#endif // _MSC_VER Test();#ifdef _MSC_VER //_CrtMemDumpAllObjectsSince(NULL); // Begins the dump FileNameIn the start of program execution _CrtDumpMemoryLeaks();#endif // _MSC_VER cout << "Press ENTER to quit : "; cin.ignore((numeric_limits<streamsize>::max)(), '\n'); } catch (...) { cout << "Unknowns Exception Thrown" << endl; }} |