ERlang堆溢出

Question

我有一个相当多的程序..

它几乎完成了..

但是我在运行大约 12 小时后看到堆崩溃。

我记得听说过如果你不递归堆栈构建，你就不能以某种方式对 erlang 进行编程。谁能提供一个例子吗？

还有什么方法可以实时监控正在堆积的进程吗？

问候

编辑-怎么样

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

     _ -> continue
  end,
  loop().

Answer 1

即使您的编辑不是尾递归：

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

一个函数的执行顺序是：receive ... end，loop()。现在，如果您收到 {sys, _} 消息，将从接收内部调用 loop/0，将上面的执行顺序转换为相当于

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

：问题是，如果您从接收中调用 loop()，VM 仍然必须存储返回点，以便在 loop() 之后就地运行 loop()代码>接收。

要使函数尾部递归，您需要执行以下任一操作：

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

或

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

调用 loop() 确实始终是函数中最后要做的事情。

Answer 2

进程循环必须是尾递归的。

不要

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", []).

请参阅：http://www.erlang.org/ doc/efficiency_guide/processes.html

Answer 3

类似的东西可以用于监视系统中进程的当前堆使用情况。只需将其放入循环 gen_server 中的打印输出中，或者每隔一段时间在 shell 中运行它即可。

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