Elixir: boucle l'acteur pour se réexécuter

Question

Je fais une application maître-ouvrier. Le code maître est le suivant. Ce code appelle de manière asynchrone les travailleurs dans start_link. Une fois que les travailleurs ont terminé leur travail, ils rapportent au maître en utilisant handle_cast appel asynchrone. Après cela, je l'intention de garder l'acteur maître « ON » afin qu'il puisse se reproduire à nouveau les nouveaux travailleurs acteurs (comme il l'a fait dans le premier appel start_link.). Cependant, le maître s'arrête une fois que tous les acteurs travailleurs ont terminé leur travail. Ce poste stackoverflow mentionne l'utilisation de l'appel récursif mais je ne suis pas en mesure de le faire avec Genserver. Y at-il une méthode dans Genserver pour y parvenir?

defmodule Bitcoin.MasterNode do 
use GenServer 

def start_link(opts) do 
    {:ok, pid} = GenServer.start_link(__MODULE__,:ok, opts) 
    start_workers(----perform some task asynchronously----) 
    {:ok, pid} 
end 

def set_message(server, name) do 
    GenServer.cast(server, {:set_message, name}) 
end 

#callbacks 
def init(:ok) do 
    names = [] 
    {:ok, names} 
end 

def handle_cast({:set_message, name},names) do 
    names = names ++ name 
    IO.puts name 
    {:noreply,names} 
end 

fin

Edit: Je application fonctionnant sur le mode i.e., maître distribué est également relié à des noeuds de travail externes. Si Master meurt, les connexions s'éteignent également. L'intention est de garder le noeud maître avec le même PID pour exécuter des temps infinis.

Answer 1

Si je bien compris votre intention, vous voulez recommencer le processus dès que tous les enfants sont faits. Si cela est vrai, il faut utiliser OTP propose au lieu d'inventer leurs propres roues :)

étendre juste l'arbre de supervision avec un autre superviseur, qui supervisera votre « maître » (Bitcoin.MasterNode,) et vous êtes tous ensemble .

Que se passera:

1. MasterSupervisor commence;
2. MasterSupervisor commence en toute transparence MasterNode en tant que travailleur avec une stratégie :one_for_one;
3. MasterNode agit exactement comme il le fait maintenant;
4. dès que tous les travailleurs ont terminé, MasterNodemeurt, ce qui est bien;
5. une fois que son enfant MasterNode est mort, MasterSupervisorle redémarrera automatiquement en raison de sa stratégie.

---

Pour garder une trace de GenServer malgré ayiez été repop ou non, on doit utiliser named servers au lieu d'exploitation PID s:

GenServer.start_link(__MODULE__,:ok, name: MyWorker)