Programmation réactive en C++ : bibliothèques RxCpp et Boost.Signals2

Programmation réactive en C++ : aperçu des bibliothèques RxCpp et Boost.Signals2

La programmation réactive (Reactive Programming) est un paradigme orienté vers les flux de données asynchrones et la propagation des changements. En C++, ce paradigme est implémenté via des bibliothèques qui permettent de traiter les événements, les signaux et les séquences de données asynchrones de manière déclarative. Dans cet article, nous examinerons deux bibliothèques clés pour la programmation réactive en C++ : RxCpp (Reactive Extensions for C++) et Boost.Signals2. Les deux bibliothèques résolvent le problème du traitement des événements, mais avec des degrés de complexité et de fonctionnalité différents.

Pourquoi la programmation réactive en C++ ?

Le code impératif traditionnel devient souvent complexe lorsqu'il s'agit de gérer des événements asynchrones, des entrées utilisateur, des requêtes réseau ou du multithreading. La programmation réactive propose :

• Une approche déclarative : Vous décrivez "ce qui" doit se produire, et non "comment".
• La composition de flux : Il est facile de combiner, filtrer et transformer des flux de données.
• La gestion du multithreading : Des mécanismes intégrés pour le changement de contexte et la synchronisation.
• La gestion des erreurs : Un pipeline unifié pour les données et les exceptions.

La bibliothèque RxCpp

RxCpp est un portage des extensions réactives (Rx) pour C++. Elle fournit un ensemble puissant d'opérateurs pour travailler avec des séquences de données asynchrones. Les concepts principaux sont : observable (source de données) et observer (abonné).

Installation

RxCpp est une bibliothèque header-only. Il suffit de cloner le dépôt et d'inclure les fichiers d'en-tête :

#include <rxcpp/rx.hpp>using namespace rxcpp;using namespace rxcpp::sources;using namespace rxcpp::operators;

Exemple 1 : Abonnement simple à un flux de nombres

Créons un observable qui génère les nombres de 1 à 5, et abonnons-nous à lui :

#include <iostream>#include <rxcpp/rx.hpp>

int main() {    auto values = range(1, 5); // observable : 1,2,3,4,5

    values.        subscribe([](int v) {            std::cout << "Reçu : " << v << std::endl;        },        []() {            std::cout << "Flux terminé" << std::endl;        });

    return 0;}

Exemple 2 : Filtrage et transformation

Les opérateurs réactifs permettent de manipuler facilement les données. Filtrons les nombres pairs et multiplions-les par 10 :

auto values = range(1, 10);

values    .filter([](int v) { return v % 2 == 0; }) // uniquement les pairs    .map([](int v) { return v * 10; })        // multiplie par 10    .subscribe([](int v) {        std::cout << "Résultat : " << v << std::endl;    });// Sortie : 20, 40, 60, 80, 100

Exemple 3 : Fusion de flux

Fusionnons deux flux avec l'opérateur merge :

auto stream1 = interval(std::chrono::milliseconds(100)).take(3);auto stream2 = interval(std::chrono::milliseconds(150)).take(3);

stream1.merge(stream2)    .subscribe([](long v) {        std::cout << v << " ";    });// Sortie possible : 0 0 1 2 1 2 (l'ordre peut varier)

La bibliothèque Boost.Signals2

Boost.Signals2 est une bibliothèque pour implémenter les signaux et les slots (signals & slots). Elle fait partie des bibliothèques Boost et fournit un mécanisme de rappel type-safe. Contrairement à RxCpp, Signals2 n'est pas conçue pour travailler avec des flux de données, mais plutôt pour le traitement d'événements discrets.

Concepts principaux

• Signal (signal) : un objet qui peut être "déclenché" et qui notifiera tous ses abonnés.
• Slot (slot) : une fonction ou un objet fonctionnel au