Erlang Heapüberlauf

Question

Ich habe ein ziemlich Programm ..

Sein fast vollständig ..

Jedoch habe ich nach ca. 12 Stunden Lauf einen Haufen Absturz sehe.

Ich erinnere mich zu hören, dass Sie Erlang nicht auf eine bestimmte Weise programmieren können, wenn nicht, wenn Sie den Stack rekursieren. Kann mir jemand ein Beispiel dafür geben ??

Und gibt es auch eine Möglichkeit, einen Echtzeitmonitor zu haben, welcher Prozess sich "stapelt"?

Grüße

EDIT - Was ist

loop() -> 
    receive 
    {sys, Msg} -> 
     handle_sys_msg(Msg), 
     loop(); 
    {From, Msg} -> 
      Reply = handle_msg(Msg), 
      From ! Reply, 
      loop(); 

    _ -> continue 
    end, 
    loop(). 

Answer 1

Auch deine Bearbeitung ist nicht tail-rekursive:

loop() -> 
    receive 
    {sys, Msg} -> 
     handle_sys_msg(Msg), 
     loop(); 
    {From, Msg} -> 
      Reply = handle_msg(Msg), 
      From ! Reply, 
      loop(); 
     _ -> continue 
    end, 
    loop(). 

Die Reihenfolge der Ausführung für eine Funktion ist: receive ... end, loop().

loop() -> 
     receive 
      loop() -> 
       receive 
        ... 
       end, 
       loop(), 
     end, 
     loop() -> 
     ... 

Das Problem ist, dass, wenn Sie loop() aus dem Empfang nennen, die: Nun, wenn Sie eine {sys, _} Nachricht erhalten, loop/0 wird aus dem erhalten, der Umwandlung die Reihenfolge der Ausführung oben in etwas Gleichwertiges zu nennen Die VM muss immer noch den Rückkehrpunkt speichern, um die loop() an Ort und Stelle nach der receive zu betreiben.

Um Ihre Funktion tail-rekursive zu machen, würden Sie tun müssen, um entweder:

loop() -> 
    receive 
    {sys, Msg} -> 
     handle_sys_msg(Msg); 
    {From, Msg} -> 
      Reply = handle_msg(Msg), 
      From ! Reply; 
     _ -> continue 
    end, 
    loop(). 

oder

loop() -> 
    receive 
    {sys, Msg} -> 
     handle_sys_msg(Msg), 
     loop(); 
    {From, Msg} -> 
      Reply = handle_msg(Msg), 
      From ! Reply, 
      loop(); 
     _ -> loop() 
    end. 

Wo loop() wirklich immer das letzte, was in der getan werden muss Aufruf Funktion.

Answer 2

Der Prozess Schleife Schwanz-rekursiv sein muss.

NICHT

loop() -> 
    receive 
    {sys, Msg} -> 
     handle_sys_msg(Msg), 
     loop(); 
    {From, Msg} -> 
      Reply = handle_msg(Msg), 
      From ! Reply, 
      loop() 
    end, 
    io:format("Message is processed~n", []). 

See: http://www.erlang.org/doc/efficiency_guide/processes.html

Answer 3

So etwas wie dies für die Überwachung der aktuellen Heap-Nutzung von Prozessen in Ihrem System verwendet werden könnten. Einfach in einen Loop-Gen-Server einlesen oder einfach mal in der Shell laufen lassen.

lists:reverse(lists:keysort(2, 
    [{Pid,catch element(2,process_info(Pid,total_heap_size))} || Pid <- processes()])).