当将杀戮消息发送到任何其他过程必须死亡的过程时，有没有办法修改？

Question

感谢您看看我的问题。

我从O'Reilly Francesco Cesarini和Simpson Thompson撰写了一个问题环问题的代码，练习4-2：过程戒指。

现在，这是我的问题，我如何修改代码，以便在将消息杀死发送到任何过程时，所有其他过程都应自动死亡，而不会通过戒指传播消息。

即使您无法解决它，也要至少感谢它。这是为了我自己对如果发生的方式会发生什么，我将再次感谢您分享代码和原始问题，以便你们能理解。

原始问题：编写一个程序，该程序将创建在环中连接的N过程，如图4-17所示。一旦开始，这些过程将在Thering周围发送M数量消息，然后在收到退出消息时优雅地终止。你可以开始 带有呼叫戒指的戒指：开始（M，N，消息）。

代码：

-module(r).
-export([start/3,processes/1]).

start(M, N, Message) ->
  io:format("Central Process pid: ~w\n", [self()]),
  { ok, NextPid } = spawner(N),
  ok = sender(Message, M, NextPid),
  ok = sender(stop, 1, NextPid),
  ok.

spawner(N) ->
  spawner(N, self()).
      
spawner(1, Nring) ->
  { ok, Nring };
            
spawner(N, Nring) ->
  Pid = spawn(r, processes, [Nring]),
  spawner(N - 1, Pid).
  
processes(Nring) ->
  loop(Nring).

loop(Nring) ->
  receive
    { stop, From } ->
      io:format("~w received stop from ~w\n", [self(), From]),
      Nring ! { stop, self() },
      ok;
    { Msg, From } ->
      io:format("~w received ~w from ~w\n", [self(), Msg, From]),
      Nring ! { Msg, self() },
      loop(Nring)
  end.
  
sender(Msg, Times, NextPid) ->
  NextPid ! { Msg, self() },
  ok = receiver(Msg),
  case Times > 1 of
    true ->
      sender(Msg, Times - 1, NextPid);
    false ->
      ok
  end.
  
receiver(Msg) ->
  receive
      { Msg, From } ->
      io:format("~w received ~w from ~w\n", [self(), Msg, From]),
      ok
  end.

如果有任何拼写错误，请原谅我，我真的很感激。太感谢了。

Answer 1

正如@brujobenavides在评论中所建议的那样，您可以链接 。如果其中一个链接过程终止，则ERLANG VM将自动终止所有其他链接过程。参见参考手册和“从“学习一些erlang for for for Great Good” 以获取更多详细信息。

在您的示例中，更改spawner/2使用spawn_link/3而不是spawn/3：

spawner(N, Nring) ->
    Pid = spawn_link(r, processes, [Nring]),
    spawner(N - 1, Pid).

此方式loop/loop/1不需要再传播{停止，PID}：

loop(Nring) ->
    receive
        { stop, From } ->
            io:format("~w received stop from ~w\n", [self(), From]),
            %% All linked processes will be terminated
            %% once we break out the loop/1
            ok;

请注意，在您的示例中，中央进程产卵其他过程也是戒指的一部分。这意味着a）每当另一个环中的一个过程中的一个和b）当中央进程死亡时，它也将被终止。

您可以通过不链接self（）来避免这种情况：

spawner(N, Nring) ->
    if Nring == self() ->
        Pid = spawn(r, processes, [Nring]);
    true ->
        Pid = spawn_link(r, processes, [Nring])
    end,
    spawner(N - 1, Pid).