Dans Erlang, passer un message à tous les éléments d'une liste de pids

Question

J'essaye de construire un serveur de synchronisation de barrière très simple, où le serveur est initialement alimenté par un certain nombre de processus qui communiqueront avec lui. Quand un processus est terminé, il reçoit un message avec ce processus 'Pid', et il conserve une liste de tous les processus pour le faire. Lorsque la barrière atteint zéro (tous les processus ont envoyé des messages), mon serveur doit envoyer un message à chacun d'eux (j'utilise [Pid | ProcList] comme ma liste de pids).

J'ai essayé d'utiliser une fonction d'aide en vain, la liste compréhensions me garder dans une boucle infinie, et en tant que tel, je suis à la recherche sur la façon d'utiliser des listes: foreach pour prendre soin de cela. Je suis assez nouveau pour la programmation fonctionnelle, mais d'après ce que je comprends, cette foreach doit prendre dans la liste ainsi qu'une fonction lambda-calcul pour envoyer un message à chaque nœud de la liste. En raison de la nature infixe de "!", Je dois encore trouver un moyen de le faire sans provoquer d'erreurs de syntaxe. Comment avez-vous fait une boucle infinie dans la compréhension de la liste?

Answer 1

Je dois dire que c'est assez difficile. Essayez ceci:

Message = % broadcast message goes here 
ListOfPids = % list of recipients 
[Pid ! Message || Pid <- ListOfPids]. 

Si vous souhaitez utiliser foreach, que cela prend une fonction d'argument comme premier argument, donc besoin d'envelopper send d'abord, car il est deux fonctions d'argument.

Message = % broadcast message goes here 
ListOfPids = % list of recipients 
Fun = fun (Pid) -> Pid ! Message end, 
lists:foreach(Fun, ListOfPids).