En utilisant des idiomes de programmation Clojure DataFlow

Question

Quelqu'un peut-il expliquer pourquoi et comment j'utiliser l'API de programmation Clojure Dataflow que je ne peux pas sembler trouver beaucoup à son sujet sur Internet.

Answer 1

Je pense qu'il est plus utile de lire d'autres informations sur ce flux de données programmation est. IMHO, le Groovy GPars gars ont certains des meilleurs documents sur flux de données. Les GPars listes de diffusion ont eu beaucoup de discussions à propos de CSP vs vs flux de données, etc acteurs dans le passé et est un excellent endroit pour poser des questions.

D'autres liens utiles:

• flux de données dans concurrency Groovy - Václav Pech (GPars)
• vive avec les données - Vaclav Pech (GPars)
• Sélectionner flux de données - Václav Pech (GPars)
• exemple de l'article GPars - Alex Miller
• Présentation - Jonas Boner (AKKA / Scala)
• Wikipedia bien sûr

Le impl est assez rudimentaire, la construction essentiellement des variables dataflow au-dessus de refs et fonctions de la montre sur les refs. Vous trouverez peut-être la ou les tests plus utile que les docs.

L'exemple canonique cité avec flux de données des variables est celle d'une feuille de calcul, où chaque variable est une cellule dans la feuille définie par les valeurs provenant d'autres cellules. Quand on change la cellule, les changements ondulent vers l'avant afin de dépendance. Dataflow variables elles-mêmes sont quelque peu limitées si -. Je pense que les flux sont là où l'dataflow idée devient plus intéressant

Dans un certain sens, l'idée de noeuds de traitement légers réguliers sur une (généralement inférieure) ensemble de fils fixes, reliés chacun par file d'attente de type flux décrit à un niveau très élevé tous {flux de données courants, les acteurs, CSP}. L'objectif étant dans tous les cas de maintenir un débit élevé en gardant les nœuds qui ont du travail à faire travailler et ne pas gaspiller des cycles sur les nœuds qui ne sont pas et aux utilisateurs Évitez la gestion des threads explicites et des verrous (découplé par les files d'attente / flux / canaux entre eux ).