Functional Reactive Programming en Java

**CyaNnOrangehead** · 19/10/2013, 15h09

Alors voilà une petite démonstration de l'étendu des possibilités offertes par une telle librairie : à télécharger ici

Ca ce lance évidement comme ceci :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
 
java -jar ReactDemo-release.jar

Et pour ceux pour qui Java est encore une option, une petite démo youtube de démontre le fonctionnement : à visionner ici

Et une petite image pour attirer l'oeil :

J'imagine assez bien les possibilité sympa qu'on pourrai avoir dans un framework de jeu vidéo, ou pour gérer les évènements d'un GUI, ou encore en robotique.

vala, c'est tout pour le moment ;-)

**thierryler** · 23/10/2013, 14h01

Tu sais quoi ? Ca vaudrait vachement le coup de mettre ce que tu viens de dire dans l'article. On peut d'ailleurs mettre des vidéos Youtube aussi avec le lecteur qui va bien. Le seul truc chiant, c'est qu'il faut faire une vignette, mais je peux m'en charger et te donner le code xml qui va bien

**CyaNnOrangehead** · 23/10/2013, 14h18

Envoyé par thierryler

Tu sais quoi ? Ca vaudrait vachement le coup de mettre ce que tu viens de dire dans l'article. On peut d'ailleurs mettre des vidéos Youtube aussi avec le lecteur qui va bien. Le seul truc chiant, c'est qu'il faut faire une vignette, mais je peux m'en charger et te donner le code xml qui va bien

Suis en plein reactoring là.
J'était partis avec trop d'objet complexe en tête de type event (comme on trouve en java) mais en fait, il fallait partir plus simple.

Bref, je reste muet tant que je n'ai pas plus avancé.
Je viens d'intégrer :
- map transforme la donnée en une autre, déclenché lors de l'évènement
- filter filtre l'évènement lui même, la periode à laquel il doit être émis
- fold, ça j'ai mis un moment, permet de faire des opération sur la donnée de l’événement précédent et celui en cours.

Ainsi que des méthode à moi :
- merge concatène le flux de deux évènements
- sync idem que merge, mais les flux s'attendent l'un l'autre de façon à en craché qu'un à chaque fois.

merge est sync sont des opération binaires (un peu comme le ou (merge) et le et (sync) pour les nombres)
- merge, émet si a ou b ont émis
- sync, n'émet que lorsque a et b ont émis
Du coup ça ce comporte très bien en cascade, c'est à dire que l'on peu créer un arbre binaire d’événements avec ces opérations.

Bref, je commence à entrevoir les possibilités de ce type d'architecture, c'est tout bonnement démentiel.
Je réfléchis à des application en robotique justement, c'est pour le moment le seul champ qui n'ai pas été exploré avec cette approche (en générale jeux vidéos, 3d et IHM).

Vala. Je ne te raconte pas les tubes d'aspirines.

**CyaNnOrangehead** · 23/10/2013, 14h21

Pour mieux ce rendre compte : http://elm-lang.org/
Ils ont des exemples de jeux vidéo. Dommage que les langage fonctionnels soient si difficiles à lire.

**CyaNnOrangehead** · 24/10/2013, 14h46

Un truc pour faire plaisir à Thierry :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
Var<Integer> a = new Var<Integer>(0);
Var<Float> average = a.fold(0f, new Signal.AverageFold<Integer>());
 
average.subscribe(new Procedure1<Float>() {
 
	@Override
	public void invoke(Float arg1) {
		System.out.println("Average=" + arg1);
	}
});
 
a.setValue(10);
a.setValue(20);
a.setValue(30);
a.setValue(40);

Et qui nous donne comme résultat :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
 
Average=5.0
Average=10.0
Average=15.0
Average=20.0

Avec un foncteur fold générique :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
public static class AverageFold<V extends Number> implements Function2<Float, Float, V> {
 
	private float i;
 
	public AverageFold() {
		this.i = 1;
	}
 
	@Override
	public Float invoke(Float arg1, V arg2) {
		float sum = arg1 * i;
		i++;
		return (sum + arg2.floatValue()) / i;
	}
}

hihi ^_^

**thierryler** · 24/10/2013, 15h15

moi, ce que je voulais, c'est avoir la vidéo dans l'article.

**CyaNnOrangehead** · 24/10/2013, 16h43

Envoyé par thierryler

moi, ce que je voulais, c'est avoir la vidéo dans l'article.

Quel article ? Celui sur les foncteurs ?
Je comptais (mais vraiment pas tout de suite) faire une autre article dédié à la FRP.
Et puis celui sur les foncteurs, il y a plein de coquilles, je m'en rend compte avec le temps :
http://www.developpez.net/forums/d13...e/#post7538579

Il faudra que je revoie plusieurs choses.
Ou du moins signaler qu'idéalement ce n'est pas comme cela qu'il faut faire.

**thierryler** · 24/10/2013, 16h48

non je parle de la vidéo que tu as mis 3 messages plus haut

**CyaNnOrangehead** · 24/10/2013, 16h56

Envoyé par thierryler

non je parle de la vidéo que tu as mis 3 messages plus haut

tu veux que je la mette directement dans le forum ?
je ne comprend pas !

**thierryler** · 24/10/2013, 20h56

Dans l'article :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
 
<animation type="flash">
  <width>640</width>
  <height>360</height>
  <param-movie>http://www.youtube.com/v/0VGU9qcjnbM</param-movie>
  <param-loop>false</param-loop>
  <param-wmode>#000000</param-wmode>
  <image src="./images/todo.png"/>
</animation>

**CyaNnOrangehead** · 24/10/2013, 21h00

Envoyé par thierryler

Dans l'article :

oui oui d'accord, mais dans quel article ?

**thierryler** · 24/10/2013, 21h01

Ah oui mince, j'oubliais que tu ne prévoyais pas un article pour ça...

**CyaNnOrangehead** · 24/10/2013, 21h05

Envoyé par thierryler

Ah oui mince, j'oubliais que tu ne prévoyais pas un article pour ça...

Disons, pas sûr. Il faudrait déjà que ma librairie fonctionne correctement.
J'ai des soucis avec les threads. Il démarrent avant les subscribe, du coup on perd les premières itérations.
Je ne sais pas comment les synchroniser vue que je ne maîtrise pas quel fonction imbriqué est la dernière....
Bref c'est le casse tête.

**CyaNnOrangehead** · 25/10/2013, 13h52

Ca y est, ça commence à ressembler à ce que je voulais :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
// when mouse is pressed say "pressed" otherwise say "released"
// concatenate message with mouse position and update each time it is necessary
 
// declare the mouse reactor
Var<String> mouseAndTime = MouseReact.hold().filter(MouseReact.BUTTON1).map(new Function1<String, Integer>() {
 
    @Override
    public String invoke(Integer value) {
        // when mouse button is pressed
        return "button pressed";
    }
}).otherwise(new Function1<String, String>() {
 
    @Override
    public String invoke(String arg1) {
        // when it is released
        return "button released";
    }
}).toVar("no button yet !").merge(mouseX, new Function2<String, String, Integer>() {
 
    @Override
    public String invoke(String arg1, Integer arg2) {
        // add mouse x position
        return arg1 + " ( x=" + arg2;
    }
}).merge(mouseY, new Function2<String, String, Integer>() {
 
    @Override
    public String invoke(String arg1, Integer arg2) {
        // add mouse y position
        return arg1 + ", y=" + arg2 + ")";
    }
});
 
label1.setText(mouseAndTime);

Le nom du projet à également changé, il s'appelle React4J maintenant :
https://bitbucket.org/yann_caron/react4j/wiki/Home

J'ai pas mal refactoriser un peu tout ça pour bien séparer les responsabilités.
Je vais maintenant m'employer à créer d'autres application de demos et faire rendre la librairie compatible avec le future JDK 8 (comme guava ne sera bientôt plus maintenu, c'est un meilleurs choix.)
Dés que j'ai des exemples en J8, ce sera plus parlant. Là le code obtenu est un peu illisible (voire carrément).

Vala. J'ai également pas mal rebosser le wiki parce que certaines notions n'étaient pas encore claire pour moi.

**CyaNnOrangehead** · 28/10/2013, 21h16

Voici un petit synoptique des méthodes que j'ai développez dans la librarie :

L'idée après c'est de créer des réseaux d'évènements avec tout ça ;-)

**CyaNnOrangehead** · 29/10/2013, 14h06

Héhé voici ce que j'obtiens avec le JDK8

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
Var<String> mouseAndTime = MouseReact.button1()
		.map(arg1->arg1 ? "button pressed" : "button released")
		.toVar("no button yet !")
		.merge(mouseX, (arg1, arg2)->arg1 + " ( x=" + arg2)
		.merge(mouseY, (arg1, arg2)->arg1 + ", y=" + arg2 + ")");
 
label1.setText(mouseAndTime);

Merci les lambdas....

**Logan Mauzaize** · 30/10/2013, 13h13

J'aime bien tes schémas

T'as essayé de regarder les notations BPMN ou Sys-ML ?
Sinon essaye d'avoir des noms plus parlant que S1, S1', S2, S3 ou Sf1

Dans l'ensemble, je ne suis pas sûr d'avoir tout suivis.

En gros, tu veux décrire un "Event Processor" ?
A quoi correspond la classe React ? Une description d'une réponse à plusieurs événements ?
Exemple de construction que je ne comprends pas new MouseReact().move().merge(new MouseReact().click());
Plutôt que de manipuler des long pour les durées tu pourrais utiliser les TimeUnit et l'interface Delayed.
Je comprends pas la différence entre "merge" et "sync". Les deux provoques une réaction dès que plusieurs événements se sont produits.
Je ne comprends le principe de "otherwise". C'est pas rapport à "filter" ?
Idem pour "toVar"
mouseX et mouseY ne sont pas déclarés
Je comprends pas comment fonctionne ton dernier exemple

Bref je suis largué complet

**CyaNnOrangehead** · 30/10/2013, 16h33

Envoyé par Nemek

Bref je suis largué complet

Pas tant que cela car tes questions sont pertinentes (en plus comme ça je me sens moins seul snirfff

)

1 - oui, à la sauce Haskell (fonctionel), c'est à dire en partant de librairies comme react banana. Ou le langage elm fonctionel également.
Je me base un peu sur mon article que j'avais écrit ou j'avais démontré que les langages à objet comme java acceptent les foncteurs grâce à des interfaces generiques et aux inner classes anonymes.

2 - Le nom n'est peu-t-être pas très bien choisi. C'est la gestion d'un évenement. Un pattern observer mais qui n'accepte pas des listeners mais une "procedure" càd une fonction sans retour

3 - MouseReact().move().merge(new MouseReact().click(), new Function2 ... mergeFunction);
On merge deux signaux mouse move et mouse click, et on traite les deux signaux d'entrée avec le foncteur mergeFunction. Du coup on as qu'une valeur de retour à chaque fois.

4 - Pourquoi pas ! Dans mon cas, ce sont des intervales de temps avec l'évènement précédent.
Pour récupérer le temps total il faut écrire un truc du genre :
TimeReact.every(100).fold (0, (t1, t2) -> t1 + t2)

5 - Question très pertinente :
merge, emet les deux signaux chaque fois que l'un des signal d'entrée à emit.
sync, n'emet les deux signaux que lorsque les deux signaux d'entrée ont emit.
then, n'émet les deux signaux que lorsque le premier suivi du second ont emits
when, n'émet les deux signaux que lorsque le second suivi du premier ont emits.

6 - Ce principe n'existe plus. Il y avait un emeteur "finish" sur la fin d'un signal long, cette notion compliquait beaucoup trop la gestion du tout.

7 - En FRP il y a trois notion :
Les Variables, qui varient dans le temps et ont une valeur d'initialisation.
Les Signal, qui varient dans le temps mais ne possèdent pas de valeur initial (comme mouse button, time every etc.)
Les constants, des valeurs qui ne varient plus mais ont une valeur initial

8 - J'ai du refactoré, ils se nomment MouseReact.positionX et MouseReact.positionY maintenant

9 - L'exemple crée un signal en concatenant dans une chaine des infos sur la souris :
Si le bouton est pressé ou pas et la position.
button1 retourne un booléen qui est transformé en String par le map juste après.
Le toVar crée une variable et l'initialise avec une valeur par défaut
On merge avec positionX de la souris, que l'on mapFolt (les deux en même temps) càd que arg1 contient la chaine précédement obtenue et arg2 la position integer en X de la souris.
Idem avec la position en Y ensuite.

Voilà. Ce qu'il faut comprendre en FRP c'est que l'idée derrière c'est que tout état du système doit pouvoir être vérifié à tout moment du programme comme vrai.
Exemple en pseudo code :
var a = 0;
var b = 0;
var sum = a + b;

print (sum); // 0
a = 7;
b = 8;
print (sum); // 15

En Java classique la dernière ligne écrirait 0.
Tout est là.
Après le reste c'est du traitement d'évènements, de la transformation (comme les liste en fonctionnel avec le map/filter/fold) et de la mise en réseau (d'ou mon petit schemat)

Vala.... Mais je suis d'accord avec toi, j'ai aussi mis un peu de temps au dépard pour bien comprendre de quoi il sagissait.

**CyaNnOrangehead** · 30/10/2013, 16h42

Pour le schemat, merci.
Il faudrai que j'ajoute la légende suivante:
S1, S2 -> signal 1 et 2
sf1 sf1 -> signal function 1 et 2

Exemple d'interprétation du filter :
Le Signal 1 émet vers le signal 2.
Le signal est filtré pas une signalFunction qui détermine si l’émission doit ce faire ou pas.

Exemple d'interprétation du map :
Le signal 1 émet vers le signal 2, la valeur du signal 1 est transformé au travers la signalFunction

Exemple d'interprétation du fold :
Le signal 1 émet vers le signal 2, la valeur du signal 1 est transformé en fonction de la valeur d'émission en cours et la précédente (dans le temps)

**thierryler** · 30/10/2013, 17h01

en plus comme ça je me sens moins seul

Regarde le sujet sur Algoid et tu vas voir que t'es pas seul ;-)

Functional Reactive Programming en Java

Langage Java

Discussions similaires

Partager

Partager