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
Forcément, puisque les variables doivent être modifiées par plusieurs threads, ces dernières sont globales. Il en va de même pour les mutex. Bref y a pas mal de variables globales au début du code. Bien voir le defer_lock dans la fonction g() à la ligne 30. J'ai rajouté le bout de code de la page 146 qui met en oeuvre this_thread::sleep_for(milliseconds{ 20 }).
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
|
#ifdef _MSC_VER#define _CRTDBG_MAP_ALLOC#include <crtdbg.h>#endif // _MSC_VER#include <iostream> #include <thread>#include <mutex> #include <chrono>using namespace std;double gMyDble = 0.0;mutex gMyMutex; // manage access to gMyDbleint gMyInt1 = 0;int gMyInt2 = 100;mutex gMutex1;mutex gMutex2;// ----------------------------------------------------------------------------void f(){ // take input from v; place result in *res unique_lock<mutex> lck{ gMyMutex }; // acquire mutex gMyDble+=3; // manipulate shared data} //release mutex implicitly// ----------------------------------------------------------------------------void g(){ unique_lock<mutex> lck1{ gMutex1, defer_lock }; // defer_lock: don’t yet try to acquire the mutex unique_lock<mutex> lck2{ gMutex2, defer_lock }; lock(lck1, lck2); //acquire both locks gMyInt1++; gMyInt2--;} // implicitly release all mutexes// ----------------------------------------------------------------------------void Test(void) { thread t1{ f }; thread t2{ f }; t1.join(); t2.join(); cout << "1 value has been manipulated (+3) by 2 threads. Its value is now : " << gMyDble << endl; thread t3{ g }; thread t4{ g }; t3.join(); t4.join(); cout << "2 values have been manipulated (+1 and -1) by 2 threads. Their values are : " << gMyInt1 << " " << gMyInt2 << endl; using namespace std::chrono; // see §11.4 p125 auto time0 = high_resolution_clock::now(); this_thread::sleep_for(milliseconds{ 20 }); auto time1 = high_resolution_clock::now(); cout << "Current thread was supposed to sleep for 20 ms" << endl; cout << duration_cast<nanoseconds>(time1 - time0).count() << " nanoseconds passed\n";}// ----------------------------------------------------------------------------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 since 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; }} |