Catégories

A tour of C++ – Le code source de l'exemple page 148

Temps de lecture : 3 minutes

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

A retenir : "Put in Promise" et "Get from Future". Pour le reste j'aime bien le fait qu'on puisse récupérer et/ou passer les exceptions. Cerise sur le gâteau la tuyauterie à l'air plus simple qu'avec les condition_variable.

Dans le code j'ai juste rajouté des commentaires et renommé quelques variables. Bine lire le début de la fonction Test() pour bien comprendre comment les choses se mettent en place et la façon dont on met en route les threads.

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
#ifdef _MSC_VER
#define _CRTDBG_MAP_ALLOC
#include <crtdbg.h>
#endif // _MSC_VER
#include <iostream>
#include <future>
using namespace std;
// ----------------------------------------------------------------------------
void Producer(promise<int>& px){                                                // a task: place the result in px
  try{                                                                          // ... compute a value for res ...
    int MyValue { 42 };
    px.set_value(MyValue);                                                      // put the value MyValue into the promise
  } catch (...) {                                                               // oops: couldn’t compute res
    px.set_exception(current_exception());                                      // pass the exception to the future’s thread. The current_exception() refers to the caught exception.
  }
}
// ----------------------------------------------------------------------------
void Consumer(future<int>& fx){                                                 // a task: get the result from fx
  try{
    int v = fx.get();                                                           // If the value isn’t there yet, the thread is blocked until it arrives
                                                                                // If the value couldn’t be computed, get() might throw an exception
                                                                                // From the system or transmitted from the task from which we were trying to get() the value
                                                                                // ... use v ...
    cout << "In Consumer(), the value is : " << v << endl;
  } catch (...) {                                                               // oops: someone couldn’t compute v
    cout << "Exception in Consumer()" << endl;
  }
}
// ----------------------------------------------------------------------------
void Test(void) {
  promise<int>  myPromise;
  future<int>   myFuture = myPromise.get_future();
  thread t1{Producer, ref(myPromise)};
  thread t2{Consumer, ref(myFuture)};
  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 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;
  }
}

Comments are closed.